replicator

Documentation

Index

• type MockBStoreOpenReadStreamInCallForReplicator
  • func (m *MockBStoreOpenReadStreamInCallForReplicator) Done() error
  • func (m *MockBStoreOpenReadStreamInCallForReplicator) Flush() error
  • func (m *MockBStoreOpenReadStreamInCallForReplicator) Read() (*cherami.ControlFlow, error)
  • func (m *MockBStoreOpenReadStreamInCallForReplicator) SetResponseHeaders(headers map[string]string) error
  • func (m *MockBStoreOpenReadStreamInCallForReplicator) Write(msg *store.ReadMessageContent) error
• type MockBStoreOpenReadStreamOutCallForReplicator
  • func (m *MockBStoreOpenReadStreamOutCallForReplicator) Done() error
  • func (m *MockBStoreOpenReadStreamOutCallForReplicator) Flush() error
  • func (m *MockBStoreOpenReadStreamOutCallForReplicator) Read() (*store.ReadMessageContent, error)
  • func (m *MockBStoreOpenReadStreamOutCallForReplicator) ResponseHeaders() (map[string]string, error)
  • func (m *MockBStoreOpenReadStreamOutCallForReplicator) Write(msg *cherami.ControlFlow) error
• type MockReplicatorClientFactory
  • func (_m *MockReplicatorClientFactory) GetReplicatorClient(zone string) (replicator.TChanReplicator, error)
  • func (_m *MockReplicatorClientFactory) SetTChannel(ch *tchannel.Channel)
• type MockTChanReplicator
  • func (m *MockTChanReplicator) CreateConsumerGroupUUID(ctx thrift.Context, createRequest *shared.CreateConsumerGroupUUIDRequest) (*shared.ConsumerGroupDescription, error)
  • func (m *MockTChanReplicator) CreateDestinationUUID(ctx thrift.Context, createRequest *shared.CreateDestinationUUIDRequest) (*shared.DestinationDescription, error)
  • func (m *MockTChanReplicator) CreateExtent(ctx thrift.Context, createRequest *shared.CreateExtentRequest) (*shared.CreateExtentResult_, error)
  • func (m *MockTChanReplicator) CreateRemoteConsumerGroupUUID(ctx thrift.Context, createRequest *shared.CreateConsumerGroupUUIDRequest) error
  • func (m *MockTChanReplicator) CreateRemoteDestinationUUID(ctx thrift.Context, createRequest *shared.CreateDestinationUUIDRequest) error
  • func (m *MockTChanReplicator) CreateRemoteExtent(ctx thrift.Context, createRequest *shared.CreateExtentRequest) error
  • func (m *MockTChanReplicator) DeleteConsumerGroup(ctx thrift.Context, deleteRequest *shared.DeleteConsumerGroupRequest) error
  • func (m *MockTChanReplicator) DeleteDestination(ctx thrift.Context, deleteRequest *shared.DeleteDestinationRequest) error
  • func (m *MockTChanReplicator) DeleteRemoteConsumerGroup(ctx thrift.Context, deleteRequest *shared.DeleteConsumerGroupRequest) error
  • func (m *MockTChanReplicator) DeleteRemoteDestination(ctx thrift.Context, deleteRequest *shared.DeleteDestinationRequest) error
  • func (m *MockTChanReplicator) ListDestinations(ctx thrift.Context, listRequest *shared.ListDestinationsRequest) (*shared.ListDestinationsResult_, error)
  • func (m *MockTChanReplicator) ListDestinationsByUUID(ctx thrift.Context, listRequest *shared.ListDestinationsByUUIDRequest) (*shared.ListDestinationsResult_, error)
  • func (m *MockTChanReplicator) ListExtentsStats(ctx thrift.Context, listRequest *shared.ListExtentsStatsRequest) (*shared.ListExtentsStatsResult_, error)
  • func (m *MockTChanReplicator) UpdateConsumerGroup(ctx thrift.Context, updateRequest *shared.UpdateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)
  • func (m *MockTChanReplicator) UpdateDestination(ctx thrift.Context, updateRequest *shared.UpdateDestinationRequest) (*shared.DestinationDescription, error)
  • func (m *MockTChanReplicator) UpdateRemoteConsumerGroup(ctx thrift.Context, updateRequest *shared.UpdateConsumerGroupRequest) error
  • func (m *MockTChanReplicator) UpdateRemoteDestination(ctx thrift.Context, updateRequest *shared.UpdateDestinationRequest) error

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