xdc

Documentation

Index

• Variables
• type HistoryRereplicator
• type HistoryRereplicatorImpl
  • 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
  • func (_m *MockHistoryRereplicator) SendMultiWorkflowHistory(_a0 string, _a1 string, _a2 string, _a3 int64, _a4 string, _a5 int64) error

Variables

var (
	// ErrEmptyHistoryRawEventBatch indicate that one single batch of history raw events is of size 0
	ErrEmptyHistoryRawEventBatch = errors.NewInternalFailureError("encounter empty history batch")

	// ErrNoHistoryRawEventBatches indicate that number of batches of history raw events is of size 0
	ErrNoHistoryRawEventBatches = errors.NewInternalFailureError("no history batches are returned")

	// ErrFristHistoryRawEventBatch indicate that first batch of history raw events is malformed
	ErrFristHistoryRawEventBatch = errors.NewInternalFailureError("encounter malformed first history batch")

	// ErrUnknownEncodingType indicate that the encoding type is unknown
	ErrUnknownEncodingType = errors.NewInternalFailureError("unknown encoding type")
)

Types

type HistoryRereplicator

type HistoryRereplicator interface {
	// SendMultiWorkflowHistory sends multiple run IDs's history events to remote
	SendMultiWorkflowHistory(domainID string, workflowID string,
		beginingRunID string, beginingFirstEventID 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.HistorySerializer, replicationTimeout time.Duration, logger bark.Logger) *HistoryRereplicatorImpl

NewHistoryRereplicator create a new HistoryRereplicatorImpl

func (*HistoryRereplicatorImpl) SendMultiWorkflowHistory

func (h *HistoryRereplicatorImpl) SendMultiWorkflowHistory(domainID string, workflowID string,
	beginingRunID string, beginingFirstEventID int64, endingRunID string, endingNextEventID int64) (err error)

SendMultiWorkflowHistory sends multiple run IDs's history events to remote

type MockHistoryRereplicator

type MockHistoryRereplicator struct {
	mock.Mock
}

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