Documentation
¶
Overview ¶
Package xdc is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( // ErrNoHistoryRawEventBatches indicate that number of batches of history raw events is of size 0 ErrNoHistoryRawEventBatches = errors.NewInternalFailureError("no history batches are returned") // ErrFirstHistoryRawEventBatch indicate that first batch of history raw events is malformed ErrFirstHistoryRawEventBatch = errors.NewInternalFailureError("encounter malformed first history batch") // ErrUnknownEncodingType indicate that the encoding type is unknown ErrUnknownEncodingType = errors.NewInternalFailureError("unknown encoding type") )
var ( // ErrSkipTask is the error to skip task due to absence of the workflow in the source cluster ErrSkipTask = errors.New("the source workflow does not exist") )
Functions ¶
This section is empty.
Types ¶
type HistoryRereplicator ¶
type HistoryRereplicator interface {
// SendMultiWorkflowHistory sends multiple run IDs's history events to remote
SendMultiWorkflowHistory(domainID string, workflowID string,
beginningRunID string, beginningFirstEventID int64, endingRunID string, endingNextEventID int64) error
}
HistoryRereplicator is the interface for resending history events to remote
type HistoryRereplicatorImpl ¶
type HistoryRereplicatorImpl struct {
// contains filtered or unexported fields
}
HistoryRereplicatorImpl is the implementation of HistoryRereplicator
func NewHistoryRereplicator ¶
func NewHistoryRereplicator( targetClusterName string, domainCache cache.DomainCache, adminClient a.Client, historyReplicationFn historyReplicationFn, serializer persistence.PayloadSerializer, replicationTimeout time.Duration, rereplicationTimeout dynamicconfig.DurationPropertyFnWithDomainIDFilter, logger log.Logger) *HistoryRereplicatorImpl
NewHistoryRereplicator create a new HistoryRereplicatorImpl
func (*HistoryRereplicatorImpl) SendMultiWorkflowHistory ¶
func (h *HistoryRereplicatorImpl) SendMultiWorkflowHistory(domainID string, workflowID string, beginningRunID string, beginningFirstEventID int64, endingRunID string, endingNextEventID int64) (err error)
SendMultiWorkflowHistory sends multiple run IDs's history events to remote
type MockHistoryRereplicator ¶
MockHistoryRereplicator is an autogenerated mock type for the HistoryRereplicator type
func (*MockHistoryRereplicator) SendMultiWorkflowHistory ¶
func (_m *MockHistoryRereplicator) SendMultiWorkflowHistory(_a0 string, _a1 string, _a2 string, _a3 int64, _a4 string, _a5 int64) error
SendMultiWorkflowHistory provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4, _a5
type MockNDCHistoryResender ¶ added in v0.10.0
type MockNDCHistoryResender struct {
// contains filtered or unexported fields
}
MockNDCHistoryResender is a mock of NDCHistoryResender interface
func NewMockNDCHistoryResender ¶ added in v0.10.0
func NewMockNDCHistoryResender(ctrl *gomock.Controller) *MockNDCHistoryResender
NewMockNDCHistoryResender creates a new mock instance
func (*MockNDCHistoryResender) EXPECT ¶ added in v0.10.0
func (m *MockNDCHistoryResender) EXPECT() *MockNDCHistoryResenderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockNDCHistoryResender) SendSingleWorkflowHistory ¶ added in v0.10.0
func (m *MockNDCHistoryResender) SendSingleWorkflowHistory(domainID, workflowID, runID string, startEventID, startEventVersion, endEventID, endEventVersion *int64) error
SendSingleWorkflowHistory mocks base method
type MockNDCHistoryResenderMockRecorder ¶ added in v0.10.0
type MockNDCHistoryResenderMockRecorder struct {
// contains filtered or unexported fields
}
MockNDCHistoryResenderMockRecorder is the mock recorder for MockNDCHistoryResender
func (*MockNDCHistoryResenderMockRecorder) SendSingleWorkflowHistory ¶ added in v0.10.0
func (mr *MockNDCHistoryResenderMockRecorder) SendSingleWorkflowHistory(domainID, workflowID, runID, startEventID, startEventVersion, endEventID, endEventVersion interface{}) *gomock.Call
SendSingleWorkflowHistory indicates an expected call of SendSingleWorkflowHistory
type NDCHistoryResender ¶ added in v0.10.0
type NDCHistoryResender interface {
// SendSingleWorkflowHistory sends multiple run IDs's history events to remote
SendSingleWorkflowHistory(
domainID string,
workflowID string,
runID string,
startEventID *int64,
startEventVersion *int64,
endEventID *int64,
endEventVersion *int64,
) error
}
NDCHistoryResender is the interface for resending history events to remote
type NDCHistoryResenderImpl ¶ added in v0.10.0
type NDCHistoryResenderImpl struct {
// contains filtered or unexported fields
}
NDCHistoryResenderImpl is the implementation of NDCHistoryResender
func NewNDCHistoryResender ¶ added in v0.10.0
func NewNDCHistoryResender( domainCache cache.DomainCache, adminClient adminClient.Client, historyReplicationFn nDCHistoryReplicationFn, serializer persistence.PayloadSerializer, rereplicationTimeout dynamicconfig.DurationPropertyFnWithDomainIDFilter, currentExecutionCheck checks.Invariant, logger log.Logger, ) *NDCHistoryResenderImpl
NewNDCHistoryResender create a new NDCHistoryResenderImpl
func (*NDCHistoryResenderImpl) SendSingleWorkflowHistory ¶ added in v0.10.0
func (n *NDCHistoryResenderImpl) SendSingleWorkflowHistory( domainID string, workflowID string, runID string, startEventID *int64, startEventVersion *int64, endEventID *int64, endEventVersion *int64, ) error
SendSingleWorkflowHistory sends one run IDs's history events to remote
Source Files