ndc

Documentation

Overview

Package ndc is a generated GoMock package.

Index

• Variables
• type HistoryResender
• type HistoryResenderImpl
  • func NewHistoryResender(domainCache cache.DomainCache, adminClient adminClient.Client, ...) *HistoryResenderImpl
  • func (n *HistoryResenderImpl) SendSingleWorkflowHistory(domainID string, workflowID string, runID string, startEventID *int64, ...) error
• type MockHistoryResender
  • func NewMockHistoryResender(ctrl *gomock.Controller) *MockHistoryResender
  • func (m *MockHistoryResender) EXPECT() *MockHistoryResenderMockRecorder
  • func (m *MockHistoryResender) SendSingleWorkflowHistory(domainID, workflowID, runID string, ...) error
• type MockHistoryResenderMockRecorder
  • func (mr *MockHistoryResenderMockRecorder) SendSingleWorkflowHistory(...) *gomock.Call

Variables

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")
)

Types

type HistoryResender

type HistoryResender 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
}

HistoryResender is the interface for resending history events to remote

type HistoryResenderImpl

type HistoryResenderImpl struct {
	// contains filtered or unexported fields
}

HistoryResenderImpl is the implementation of NDCHistoryResender

func NewHistoryResender

func NewHistoryResender(
	domainCache cache.DomainCache,
	adminClient adminClient.Client,
	historyReplicationFn nDCHistoryReplicationFn,
	serializer persistence.PayloadSerializer,
	rereplicationTimeout dynamicconfig.DurationPropertyFnWithDomainIDFilter,
	currentExecutionCheck invariant.Invariant,
	logger log.Logger,
) *HistoryResenderImpl

NewHistoryResender create a new NDCHistoryResenderImpl

func (*HistoryResenderImpl) SendSingleWorkflowHistory

func (n *HistoryResenderImpl) 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

type MockHistoryResender

type MockHistoryResender struct {
	// contains filtered or unexported fields
}

MockHistoryResender is a mock of HistoryResender interface

func NewMockHistoryResender

func NewMockHistoryResender(ctrl *gomock.Controller) *MockHistoryResender

NewMockHistoryResender creates a new mock instance

func (*MockHistoryResender) EXPECT

func (m *MockHistoryResender) EXPECT() *MockHistoryResenderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockHistoryResender) SendSingleWorkflowHistory

func (m *MockHistoryResender) SendSingleWorkflowHistory(domainID, workflowID, runID string, startEventID, startEventVersion, endEventID, endEventVersion *int64) error

SendSingleWorkflowHistory mocks base method

type MockHistoryResenderMockRecorder

type MockHistoryResenderMockRecorder struct {
	// contains filtered or unexported fields
}

MockHistoryResenderMockRecorder is the mock recorder for MockHistoryResender

func (*MockHistoryResenderMockRecorder) SendSingleWorkflowHistory

func (mr *MockHistoryResenderMockRecorder) SendSingleWorkflowHistory(domainID, workflowID, runID, startEventID, startEventVersion, endEventID, endEventVersion interface{}) *gomock.Call

SendSingleWorkflowHistory indicates an expected call of SendSingleWorkflowHistory