replicator

package
v1.20.0-rc0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 8, 2017 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBStoreOpenReadStreamInCallForReplicator 

type MockBStoreOpenReadStreamInCallForReplicator struct {
	mock.Mock
}

MockBStoreOpenReadStreamInCallForReplicator is the mock of store.BStoreOpenReadStreamInCall

func (*MockBStoreOpenReadStreamInCallForReplicator) Done 

func (m *MockBStoreOpenReadStreamInCallForReplicator) Done() error

Done is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamInCallForReplicator) Flush 

func (m *MockBStoreOpenReadStreamInCallForReplicator) Flush() error

Flush is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamInCallForReplicator) Read 

func (m *MockBStoreOpenReadStreamInCallForReplicator) Read() (*cherami.ControlFlow, error)

Read is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamInCallForReplicator) SetResponseHeaders 

func (m *MockBStoreOpenReadStreamInCallForReplicator) SetResponseHeaders(headers map[string]string) error

SetResponseHeaders is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamInCallForReplicator) Write 

func (m *MockBStoreOpenReadStreamInCallForReplicator) Write(msg *store.ReadMessageContent) error

Write is the mock of the corresponding store. method

type MockBStoreOpenReadStreamOutCallForReplicator 

type MockBStoreOpenReadStreamOutCallForReplicator struct {
	mock.Mock
}

MockBStoreOpenReadStreamOutCallForReplicator is the mock of store.BStoreOpenReadStreamOutCall this is used for replicator test

func (*MockBStoreOpenReadStreamOutCallForReplicator) Done 

func (m *MockBStoreOpenReadStreamOutCallForReplicator) Done() error

Done is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCallForReplicator) Flush 

func (m *MockBStoreOpenReadStreamOutCallForReplicator) Flush() error

Flush is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCallForReplicator) Read 

func (m *MockBStoreOpenReadStreamOutCallForReplicator) Read() (*store.ReadMessageContent, error)

Read is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCallForReplicator) ResponseHeaders 

func (m *MockBStoreOpenReadStreamOutCallForReplicator) ResponseHeaders() (map[string]string, error)

ResponseHeaders is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCallForReplicator) Write 

func (m *MockBStoreOpenReadStreamOutCallForReplicator) Write(msg *cherami.ControlFlow) error

Write is the mock of the corresponding store. method

type MockReplicatorClientFactory 

type MockReplicatorClientFactory struct {
	mock.Mock
}

MockReplicatorClientFactory is the mock implementation for ReplicatorClientFactory and used for testing

func (*MockReplicatorClientFactory) GetReplicatorClient 

func (_m *MockReplicatorClientFactory) GetReplicatorClient(zone string) (replicator.TChanReplicator, error)

GetReplicatorClient is the mock for corresponding replicator API

func (*MockReplicatorClientFactory) SetTChannel 

func (_m *MockReplicatorClientFactory) SetTChannel(ch *tchannel.Channel)

SetTChannel is the mock for corresponding replicator API

type MockTChanReplicator 

type MockTChanReplicator struct {
	mock.Mock
}

MockTChanReplicator is the mock implementation for replicator and used for testing

func (*MockTChanReplicator) CreateConsumerGroupExtent added in v1.26.0 

func (m *MockTChanReplicator) CreateConsumerGroupExtent(ctx thrift.Context, createRequest *shared.CreateConsumerGroupExtentRequest) error

func (*MockTChanReplicator) CreateConsumerGroupUUID 

func (m *MockTChanReplicator) CreateConsumerGroupUUID(ctx thrift.Context, createRequest *shared.CreateConsumerGroupUUIDRequest) (*shared.ConsumerGroupDescription, error)

CreateConsumerGroupUUID is the mock for corresponding replicator API

func (*MockTChanReplicator) CreateDestinationUUID 

func (m *MockTChanReplicator) CreateDestinationUUID(ctx thrift.Context, createRequest *shared.CreateDestinationUUIDRequest) (*shared.DestinationDescription, error)

CreateDestinationUUID is the mock for corresponding replicator API

func (*MockTChanReplicator) CreateExtent 

func (m *MockTChanReplicator) CreateExtent(ctx thrift.Context, createRequest *shared.CreateExtentRequest) (*shared.CreateExtentResult_, error)

func (*MockTChanReplicator) CreateRemoteConsumerGroupExtent added in v1.26.0 

func (m *MockTChanReplicator) CreateRemoteConsumerGroupExtent(ctx thrift.Context, createRequest *shared.CreateConsumerGroupExtentRequest) error

func (*MockTChanReplicator) CreateRemoteConsumerGroupUUID 

func (m *MockTChanReplicator) CreateRemoteConsumerGroupUUID(ctx thrift.Context, createRequest *shared.CreateConsumerGroupUUIDRequest) error

CreateRemoteConsumerGroupUUID is the mock for corresponding replicator API

func (*MockTChanReplicator) CreateRemoteDestinationUUID 

func (m *MockTChanReplicator) CreateRemoteDestinationUUID(ctx thrift.Context, createRequest *shared.CreateDestinationUUIDRequest) error

CreateRemoteDestinationUUID is the mock for corresponding replicator API

func (*MockTChanReplicator) CreateRemoteExtent 

func (m *MockTChanReplicator) CreateRemoteExtent(ctx thrift.Context, createRequest *shared.CreateExtentRequest) error

func (*MockTChanReplicator) DeleteConsumerGroup 

func (m *MockTChanReplicator) DeleteConsumerGroup(ctx thrift.Context, deleteRequest *shared.DeleteConsumerGroupRequest) error

DeleteConsumerGroup is the mock for corresponding replicator API

func (*MockTChanReplicator) DeleteDestination 

func (m *MockTChanReplicator) DeleteDestination(ctx thrift.Context, deleteRequest *shared.DeleteDestinationRequest) error

DeleteDestination is the mock for corresponding replicator API

func (*MockTChanReplicator) DeleteRemoteConsumerGroup 

func (m *MockTChanReplicator) DeleteRemoteConsumerGroup(ctx thrift.Context, deleteRequest *shared.DeleteConsumerGroupRequest) error

DeleteRemoteConsumerGroup is the mock for corresponding replicator API

func (*MockTChanReplicator) DeleteRemoteDestination 

func (m *MockTChanReplicator) DeleteRemoteDestination(ctx thrift.Context, deleteRequest *shared.DeleteDestinationRequest) error

DeleteRemoteDestination is the mock for corresponding replicator API

func (*MockTChanReplicator) ListConsumerGroups added in v1.26.0 

func (m *MockTChanReplicator) ListConsumerGroups(ctx thrift.Context, listRequest *shared.ListConsumerGroupRequest) (*shared.ListConsumerGroupResult_, error)

func (*MockTChanReplicator) ListDestinations 

func (m *MockTChanReplicator) ListDestinations(ctx thrift.Context, listRequest *shared.ListDestinationsRequest) (*shared.ListDestinationsResult_, error)

func (*MockTChanReplicator) ListDestinationsByUUID 

func (m *MockTChanReplicator) ListDestinationsByUUID(ctx thrift.Context, listRequest *shared.ListDestinationsByUUIDRequest) (*shared.ListDestinationsResult_, error)

func (*MockTChanReplicator) ListExtentsStats 

func (m *MockTChanReplicator) ListExtentsStats(ctx thrift.Context, listRequest *shared.ListExtentsStatsRequest) (*shared.ListExtentsStatsResult_, error)

func (*MockTChanReplicator) ReadConsumerGroupExtents added in v1.26.0 

func (m *MockTChanReplicator) ReadConsumerGroupExtents(ctx thrift.Context, listRequest *shared.ReadConsumerGroupExtentsRequest) (*shared.ReadConsumerGroupExtentsResult_, error)

func (*MockTChanReplicator) ReadDestination added in v1.26.0 

func (m *MockTChanReplicator) ReadDestination(ctx thrift.Context, listRequest *shared.ReadDestinationRequest) (*shared.DestinationDescription, error)

func (*MockTChanReplicator) SetAckOffset added in v1.26.0 

func (m *MockTChanReplicator) SetAckOffset(ctx thrift.Context, request *shared.SetAckOffsetRequest) error

func (*MockTChanReplicator) SetAckOffsetInRemote added in v1.26.0 

func (m *MockTChanReplicator) SetAckOffsetInRemote(ctx thrift.Context, request *shared.SetAckOffsetRequest) error

func (*MockTChanReplicator) UpdateConsumerGroup 

func (m *MockTChanReplicator) UpdateConsumerGroup(ctx thrift.Context, updateRequest *shared.UpdateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

UpdateConsumerGroup is the mock for corresponding replicator API

func (*MockTChanReplicator) UpdateDestination 

func (m *MockTChanReplicator) UpdateDestination(ctx thrift.Context, updateRequest *shared.UpdateDestinationRequest) (*shared.DestinationDescription, error)

UpdateDestination is the mock for corresponding replicator API

func (*MockTChanReplicator) UpdateRemoteConsumerGroup 

func (m *MockTChanReplicator) UpdateRemoteConsumerGroup(ctx thrift.Context, updateRequest *shared.UpdateConsumerGroupRequest) error

UpdateRemoteConsumerGroup is the mock for corresponding replicator API

func (*MockTChanReplicator) UpdateRemoteDestination 

func (m *MockTChanReplicator) UpdateRemoteDestination(ctx thrift.Context, updateRequest *shared.UpdateDestinationRequest) error

UpdateRemoteDestination is the mock for corresponding replicator API

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.