replicator

package
v0.2.0-rc1 Latest Latest
Warning

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

Go to latest
Published: Feb 20, 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

Done is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamInCallForReplicator) Flush

Flush is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamInCallForReplicator) Read

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

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

Done is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCallForReplicator) Flush

Flush is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCallForReplicator) Read

Read is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCallForReplicator) ResponseHeaders

ResponseHeaders is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCallForReplicator) Write

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

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 (*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 (*MockTChanReplicator) ListDestinationsByUUID

func (*MockTChanReplicator) ListExtentsStats

func (*MockTChanReplicator) UpdateConsumerGroup

UpdateConsumerGroup is the mock for corresponding replicator API

func (*MockTChanReplicator) UpdateDestination

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL