Documentation
¶
Overview ¶
Package xdc is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockNDCHistoryResender ¶ added in v0.27.0
type MockNDCHistoryResender struct {
// contains filtered or unexported fields
}
MockNDCHistoryResender is a mock of NDCHistoryResender interface.
func NewMockNDCHistoryResender ¶ added in v0.27.0
func NewMockNDCHistoryResender(ctrl *gomock.Controller) *MockNDCHistoryResender
NewMockNDCHistoryResender creates a new mock instance.
func (*MockNDCHistoryResender) EXPECT ¶ added in v0.27.0
func (m *MockNDCHistoryResender) EXPECT() *MockNDCHistoryResenderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockNDCHistoryResender) SendSingleWorkflowHistory ¶ added in v0.27.0
func (m *MockNDCHistoryResender) SendSingleWorkflowHistory(ctx context.Context, remoteClusterName string, namespaceID namespace.ID, workflowID, runID string, startEventID, startEventVersion, endEventID, endEventVersion int64) error
SendSingleWorkflowHistory mocks base method.
type MockNDCHistoryResenderMockRecorder ¶ added in v0.27.0
type MockNDCHistoryResenderMockRecorder struct {
// contains filtered or unexported fields
}
MockNDCHistoryResenderMockRecorder is the mock recorder for MockNDCHistoryResender.
func (*MockNDCHistoryResenderMockRecorder) SendSingleWorkflowHistory ¶ added in v0.27.0
func (mr *MockNDCHistoryResenderMockRecorder) SendSingleWorkflowHistory(ctx, remoteClusterName, namespaceID, workflowID, runID, startEventID, startEventVersion, endEventID, endEventVersion any) *gomock.Call
SendSingleWorkflowHistory indicates an expected call of SendSingleWorkflowHistory.
type NDCHistoryResender ¶ added in v0.27.0
type NDCHistoryResender interface {
// SendSingleWorkflowHistory sends multiple run IDs's history events to remote
SendSingleWorkflowHistory(
ctx context.Context,
remoteClusterName string,
namespaceID namespace.ID,
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.27.0
type NDCHistoryResenderImpl struct {
// contains filtered or unexported fields
}
NDCHistoryResenderImpl is the implementation of NDCHistoryResender
func NewNDCHistoryResender ¶ added in v0.27.0
func NewNDCHistoryResender( namespaceRegistry namespace.Registry, clientBean client.Bean, historyReplicationFn nDCHistoryReplicationFn, serializer serialization.Serializer, rereplicationTimeout dynamicconfig.DurationPropertyFnWithNamespaceIDFilter, logger log.Logger, config *configs.Config, ) *NDCHistoryResenderImpl
NewNDCHistoryResender create a new NDCHistoryResenderImpl
func (*NDCHistoryResenderImpl) ApplyReplicateFn ¶ added in v1.24.0
func (n *NDCHistoryResenderImpl) ApplyReplicateFn( ctx context.Context, sourceClusterName string, namespaceId namespace.ID, workflowId string, runId string, events [][]*historypb.HistoryEvent, versionHistory []*historyspb.VersionHistoryItem, ) error
func (*NDCHistoryResenderImpl) SendSingleWorkflowHistory ¶ added in v0.27.0
func (n *NDCHistoryResenderImpl) SendSingleWorkflowHistory( ctx context.Context, remoteClusterName string, namespaceID namespace.ID, 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