common/persistence/serializer_mock.go (287 lines of code) (raw):
// The MIT License (MIT)
// Copyright (c) 2017-2020 Uber Technologies Inc.
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in all
// copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
// SOFTWARE.
// Code generated by MockGen. DO NOT EDIT.
// Source: github.com/uber/cadence/common/persistence (interfaces: PayloadSerializer)
// Package persistence is a generated GoMock package.
package persistence
import (
reflect "reflect"
gomock "github.com/golang/mock/gomock"
common "github.com/uber/cadence/common"
checksum "github.com/uber/cadence/common/checksum"
types "github.com/uber/cadence/common/types"
)
// MockPayloadSerializer is a mock of PayloadSerializer interface.
type MockPayloadSerializer struct {
ctrl *gomock.Controller
recorder *MockPayloadSerializerMockRecorder
}
// MockPayloadSerializerMockRecorder is the mock recorder for MockPayloadSerializer.
type MockPayloadSerializerMockRecorder struct {
mock *MockPayloadSerializer
}
// NewMockPayloadSerializer creates a new mock instance.
func NewMockPayloadSerializer(ctrl *gomock.Controller) *MockPayloadSerializer {
mock := &MockPayloadSerializer{ctrl: ctrl}
mock.recorder = &MockPayloadSerializerMockRecorder{mock}
return mock
}
// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockPayloadSerializer) EXPECT() *MockPayloadSerializerMockRecorder {
return m.recorder
}
// DeserializeAsyncWorkflowsConfig mocks base method.
func (m *MockPayloadSerializer) DeserializeAsyncWorkflowsConfig(arg0 *DataBlob) (*types.AsyncWorkflowConfiguration, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeAsyncWorkflowsConfig", arg0)
ret0, _ := ret[0].(*types.AsyncWorkflowConfiguration)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeAsyncWorkflowsConfig indicates an expected call of DeserializeAsyncWorkflowsConfig.
func (mr *MockPayloadSerializerMockRecorder) DeserializeAsyncWorkflowsConfig(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeAsyncWorkflowsConfig", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeAsyncWorkflowsConfig), arg0)
}
// DeserializeBadBinaries mocks base method.
func (m *MockPayloadSerializer) DeserializeBadBinaries(arg0 *DataBlob) (*types.BadBinaries, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeBadBinaries", arg0)
ret0, _ := ret[0].(*types.BadBinaries)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeBadBinaries indicates an expected call of DeserializeBadBinaries.
func (mr *MockPayloadSerializerMockRecorder) DeserializeBadBinaries(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeBadBinaries", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeBadBinaries), arg0)
}
// DeserializeBatchEvents mocks base method.
func (m *MockPayloadSerializer) DeserializeBatchEvents(arg0 *DataBlob) ([]*types.HistoryEvent, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeBatchEvents", arg0)
ret0, _ := ret[0].([]*types.HistoryEvent)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeBatchEvents indicates an expected call of DeserializeBatchEvents.
func (mr *MockPayloadSerializerMockRecorder) DeserializeBatchEvents(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeBatchEvents", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeBatchEvents), arg0)
}
// DeserializeChecksum mocks base method.
func (m *MockPayloadSerializer) DeserializeChecksum(arg0 *DataBlob) (checksum.Checksum, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeChecksum", arg0)
ret0, _ := ret[0].(checksum.Checksum)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeChecksum indicates an expected call of DeserializeChecksum.
func (mr *MockPayloadSerializerMockRecorder) DeserializeChecksum(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeChecksum", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeChecksum), arg0)
}
// DeserializeDynamicConfigBlob mocks base method.
func (m *MockPayloadSerializer) DeserializeDynamicConfigBlob(arg0 *DataBlob) (*types.DynamicConfigBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeDynamicConfigBlob", arg0)
ret0, _ := ret[0].(*types.DynamicConfigBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeDynamicConfigBlob indicates an expected call of DeserializeDynamicConfigBlob.
func (mr *MockPayloadSerializerMockRecorder) DeserializeDynamicConfigBlob(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeDynamicConfigBlob", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeDynamicConfigBlob), arg0)
}
// DeserializeEvent mocks base method.
func (m *MockPayloadSerializer) DeserializeEvent(arg0 *DataBlob) (*types.HistoryEvent, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeEvent", arg0)
ret0, _ := ret[0].(*types.HistoryEvent)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeEvent indicates an expected call of DeserializeEvent.
func (mr *MockPayloadSerializerMockRecorder) DeserializeEvent(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeEvent", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeEvent), arg0)
}
// DeserializeIsolationGroups mocks base method.
func (m *MockPayloadSerializer) DeserializeIsolationGroups(arg0 *DataBlob) (*types.IsolationGroupConfiguration, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeIsolationGroups", arg0)
ret0, _ := ret[0].(*types.IsolationGroupConfiguration)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeIsolationGroups indicates an expected call of DeserializeIsolationGroups.
func (mr *MockPayloadSerializerMockRecorder) DeserializeIsolationGroups(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeIsolationGroups", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeIsolationGroups), arg0)
}
// DeserializePendingFailoverMarkers mocks base method.
func (m *MockPayloadSerializer) DeserializePendingFailoverMarkers(arg0 *DataBlob) ([]*types.FailoverMarkerAttributes, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializePendingFailoverMarkers", arg0)
ret0, _ := ret[0].([]*types.FailoverMarkerAttributes)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializePendingFailoverMarkers indicates an expected call of DeserializePendingFailoverMarkers.
func (mr *MockPayloadSerializerMockRecorder) DeserializePendingFailoverMarkers(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializePendingFailoverMarkers", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializePendingFailoverMarkers), arg0)
}
// DeserializeProcessingQueueStates mocks base method.
func (m *MockPayloadSerializer) DeserializeProcessingQueueStates(arg0 *DataBlob) (*types.ProcessingQueueStates, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeProcessingQueueStates", arg0)
ret0, _ := ret[0].(*types.ProcessingQueueStates)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeProcessingQueueStates indicates an expected call of DeserializeProcessingQueueStates.
func (mr *MockPayloadSerializerMockRecorder) DeserializeProcessingQueueStates(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeProcessingQueueStates", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeProcessingQueueStates), arg0)
}
// DeserializeResetPoints mocks base method.
func (m *MockPayloadSerializer) DeserializeResetPoints(arg0 *DataBlob) (*types.ResetPoints, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeResetPoints", arg0)
ret0, _ := ret[0].(*types.ResetPoints)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeResetPoints indicates an expected call of DeserializeResetPoints.
func (mr *MockPayloadSerializerMockRecorder) DeserializeResetPoints(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeResetPoints", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeResetPoints), arg0)
}
// DeserializeVersionHistories mocks base method.
func (m *MockPayloadSerializer) DeserializeVersionHistories(arg0 *DataBlob) (*types.VersionHistories, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeVersionHistories", arg0)
ret0, _ := ret[0].(*types.VersionHistories)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeVersionHistories indicates an expected call of DeserializeVersionHistories.
func (mr *MockPayloadSerializerMockRecorder) DeserializeVersionHistories(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeVersionHistories", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeVersionHistories), arg0)
}
// DeserializeVisibilityMemo mocks base method.
func (m *MockPayloadSerializer) DeserializeVisibilityMemo(arg0 *DataBlob) (*types.Memo, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "DeserializeVisibilityMemo", arg0)
ret0, _ := ret[0].(*types.Memo)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeserializeVisibilityMemo indicates an expected call of DeserializeVisibilityMemo.
func (mr *MockPayloadSerializerMockRecorder) DeserializeVisibilityMemo(arg0 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeserializeVisibilityMemo", reflect.TypeOf((*MockPayloadSerializer)(nil).DeserializeVisibilityMemo), arg0)
}
// SerializeAsyncWorkflowsConfig mocks base method.
func (m *MockPayloadSerializer) SerializeAsyncWorkflowsConfig(arg0 *types.AsyncWorkflowConfiguration, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeAsyncWorkflowsConfig", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeAsyncWorkflowsConfig indicates an expected call of SerializeAsyncWorkflowsConfig.
func (mr *MockPayloadSerializerMockRecorder) SerializeAsyncWorkflowsConfig(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeAsyncWorkflowsConfig", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeAsyncWorkflowsConfig), arg0, arg1)
}
// SerializeBadBinaries mocks base method.
func (m *MockPayloadSerializer) SerializeBadBinaries(arg0 *types.BadBinaries, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeBadBinaries", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeBadBinaries indicates an expected call of SerializeBadBinaries.
func (mr *MockPayloadSerializerMockRecorder) SerializeBadBinaries(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeBadBinaries", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeBadBinaries), arg0, arg1)
}
// SerializeBatchEvents mocks base method.
func (m *MockPayloadSerializer) SerializeBatchEvents(arg0 []*types.HistoryEvent, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeBatchEvents", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeBatchEvents indicates an expected call of SerializeBatchEvents.
func (mr *MockPayloadSerializerMockRecorder) SerializeBatchEvents(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeBatchEvents", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeBatchEvents), arg0, arg1)
}
// SerializeChecksum mocks base method.
func (m *MockPayloadSerializer) SerializeChecksum(arg0 checksum.Checksum, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeChecksum", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeChecksum indicates an expected call of SerializeChecksum.
func (mr *MockPayloadSerializerMockRecorder) SerializeChecksum(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeChecksum", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeChecksum), arg0, arg1)
}
// SerializeDynamicConfigBlob mocks base method.
func (m *MockPayloadSerializer) SerializeDynamicConfigBlob(arg0 *types.DynamicConfigBlob, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeDynamicConfigBlob", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeDynamicConfigBlob indicates an expected call of SerializeDynamicConfigBlob.
func (mr *MockPayloadSerializerMockRecorder) SerializeDynamicConfigBlob(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeDynamicConfigBlob", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeDynamicConfigBlob), arg0, arg1)
}
// SerializeEvent mocks base method.
func (m *MockPayloadSerializer) SerializeEvent(arg0 *types.HistoryEvent, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeEvent", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeEvent indicates an expected call of SerializeEvent.
func (mr *MockPayloadSerializerMockRecorder) SerializeEvent(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeEvent", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeEvent), arg0, arg1)
}
// SerializeIsolationGroups mocks base method.
func (m *MockPayloadSerializer) SerializeIsolationGroups(arg0 *types.IsolationGroupConfiguration, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeIsolationGroups", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeIsolationGroups indicates an expected call of SerializeIsolationGroups.
func (mr *MockPayloadSerializerMockRecorder) SerializeIsolationGroups(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeIsolationGroups", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeIsolationGroups), arg0, arg1)
}
// SerializePendingFailoverMarkers mocks base method.
func (m *MockPayloadSerializer) SerializePendingFailoverMarkers(arg0 []*types.FailoverMarkerAttributes, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializePendingFailoverMarkers", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializePendingFailoverMarkers indicates an expected call of SerializePendingFailoverMarkers.
func (mr *MockPayloadSerializerMockRecorder) SerializePendingFailoverMarkers(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializePendingFailoverMarkers", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializePendingFailoverMarkers), arg0, arg1)
}
// SerializeProcessingQueueStates mocks base method.
func (m *MockPayloadSerializer) SerializeProcessingQueueStates(arg0 *types.ProcessingQueueStates, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeProcessingQueueStates", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeProcessingQueueStates indicates an expected call of SerializeProcessingQueueStates.
func (mr *MockPayloadSerializerMockRecorder) SerializeProcessingQueueStates(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeProcessingQueueStates", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeProcessingQueueStates), arg0, arg1)
}
// SerializeResetPoints mocks base method.
func (m *MockPayloadSerializer) SerializeResetPoints(arg0 *types.ResetPoints, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeResetPoints", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeResetPoints indicates an expected call of SerializeResetPoints.
func (mr *MockPayloadSerializerMockRecorder) SerializeResetPoints(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeResetPoints", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeResetPoints), arg0, arg1)
}
// SerializeVersionHistories mocks base method.
func (m *MockPayloadSerializer) SerializeVersionHistories(arg0 *types.VersionHistories, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeVersionHistories", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeVersionHistories indicates an expected call of SerializeVersionHistories.
func (mr *MockPayloadSerializerMockRecorder) SerializeVersionHistories(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeVersionHistories", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeVersionHistories), arg0, arg1)
}
// SerializeVisibilityMemo mocks base method.
func (m *MockPayloadSerializer) SerializeVisibilityMemo(arg0 *types.Memo, arg1 common.EncodingType) (*DataBlob, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SerializeVisibilityMemo", arg0, arg1)
ret0, _ := ret[0].(*DataBlob)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SerializeVisibilityMemo indicates an expected call of SerializeVisibilityMemo.
func (mr *MockPayloadSerializerMockRecorder) SerializeVisibilityMemo(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SerializeVisibilityMemo", reflect.TypeOf((*MockPayloadSerializer)(nil).SerializeVisibilityMemo), arg0, arg1)
}