xdc

Sep 14, 2020

Changes in this version

+ var ErrSkipTask = errors.New("the source workflow does not exist")

Oct 18, 2019

Changes in this version

+ type MockNDCHistoryResender struct

+ func NewMockNDCHistoryResender(ctrl *gomock.Controller) *MockNDCHistoryResender

+ func (m *MockNDCHistoryResender) EXPECT() *MockNDCHistoryResenderMockRecorder

+ func (m *MockNDCHistoryResender) SendSingleWorkflowHistory(domainID, workflowID, runID string, ...) error

+ type MockNDCHistoryResenderMockRecorder struct

+ func (mr *MockNDCHistoryResenderMockRecorder) SendSingleWorkflowHistory(...) *gomock.Call

+ type NDCHistoryResender interface

+ SendSingleWorkflowHistory func(domainID string, workflowID string, runID string, startEventID *int64, ...) error

+ type NDCHistoryResenderImpl struct

+ func NewNDCHistoryResender(domainCache cache.DomainCache, adminClient adminClient.Client, ...) *NDCHistoryResenderImpl

+ func (n *NDCHistoryResenderImpl) SendSingleWorkflowHistory(domainID string, workflowID string, runID string, startEventID *int64, ...) error

May 8, 2019

Changes in this version

+ var ErrFirstHistoryRawEventBatch = errors.NewInternalFailureError("encounter malformed first history batch")

Jan 7, 2019

Changes in this version

+ var ErrEmptyHistoryRawEventBatch = errors.NewInternalFailureError("encounter empty history batch")

+ var ErrFristHistoryRawEventBatch = errors.NewInternalFailureError("encounter malformed first history batch")

+ var ErrNoHistoryRawEventBatches = errors.NewInternalFailureError("no history batches are returned")

+ var ErrUnknownEncodingType = errors.NewInternalFailureError("unknown encoding type")

+ type HistoryRereplicator interface

+ SendMultiWorkflowHistory func(domainID string, workflowID string, beginingRunID string, ...) error

+ type HistoryRereplicatorImpl struct

+ func NewHistoryRereplicator(targetClusterName string, domainCache cache.DomainCache, adminClient a.Client, ...) *HistoryRereplicatorImpl

+ func (h *HistoryRereplicatorImpl) SendMultiWorkflowHistory(domainID string, workflowID string, beginingRunID string, ...) (err error)

+ type MockHistoryRereplicator struct

+ func (_m *MockHistoryRereplicator) SendMultiWorkflowHistory(_a0 string, _a1 string, _a2 string, _a3 int64, _a4 string, _a5 int64) error