common

Documentation

Index

• type MockClientFactory
  • func (m *MockClientFactory) GetAdminControllerClient() (admin.TChanControllerHostAdmin, error)
  • func (m *MockClientFactory) GetControllerClient() (controller.TChanController, error)
  • func (m *MockClientFactory) GetReplicatorClient() (replicator.TChanReplicator, error)
  • func (m *MockClientFactory) GetThriftStoreClient(replica string, id string) (store.TChanBStore, error)
  • func (m *MockClientFactory) GetThriftStoreClientUUID(storeUUID string, contextID string) (store.TChanBStore, string, error)
  • func (m *MockClientFactory) ReleaseThriftStoreClient(id string)
• type MockHTTPResponseWriter
  • func (_m *MockHTTPResponseWriter) Header() http.Header
  • func (_m *MockHTTPResponseWriter) Write(_a0 []byte) (int, error)
  • func (_m *MockHTTPResponseWriter) WriteHeader(_a0 int)
• type MockTokenBucket
  • func (m *MockTokenBucket) Consume(count int, timeout time.Duration) bool
  • func (m *MockTokenBucket) TryConsume(count int) (bool, time.Duration)
• type MockWSConnector
  • func (_m *MockWSConnector) AcceptAppendStream(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenAppendStreamInCall, error)
  • func (_m *MockWSConnector) AcceptConsumerStream(w http.ResponseWriter, r *http.Request) (serverStream.BOutOpenConsumerStreamInCall, error)
  • func (_m *MockWSConnector) AcceptPublisherStream(w http.ResponseWriter, r *http.Request) (serverStream.BInOpenPublisherStreamInCall, error)
  • func (_m *MockWSConnector) AcceptReadStream(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenReadStreamInCall, error)
  • func (_m *MockWSConnector) AcceptReplicationReadStream(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenReadStreamInCall, error)
  • func (_m *MockWSConnector) AcceptReplicationRemoteReadStream(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenReadStreamInCall, error)
  • func (_m *MockWSConnector) OpenAppendStream(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenAppendStreamOutCall, error)
  • func (_m *MockWSConnector) OpenConsumerStream(hostPort string, requestHeader http.Header) (clientStream.BOutOpenConsumerStreamOutCall, error)
  • func (_m *MockWSConnector) OpenPublisherStream(hostPort string, requestHeader http.Header) (clientStream.BInOpenPublisherStreamOutCall, error)
  • func (_m *MockWSConnector) OpenReadStream(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenReadStreamOutCall, error)
  • func (_m *MockWSConnector) OpenReplicationReadStream(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenReadStreamOutCall, error)
  • func (_m *MockWSConnector) OpenReplicationRemoteReadStream(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenReadStreamOutCall, error)

Types

type MockClientFactory

type MockClientFactory struct {
	mock.Mock
}

MockClientFactory is the mock of common.ClientFactory interface

func (*MockClientFactory) GetAdminControllerClient

func (m *MockClientFactory) GetAdminControllerClient() (admin.TChanControllerHostAdmin, error)

GetAdminControllerClient is a mock of the corresponding common. routine

func (*MockClientFactory) GetControllerClient

func (m *MockClientFactory) GetControllerClient() (controller.TChanController, error)

GetControllerClient is a mock of the corresponding common. routine

func (*MockClientFactory) GetReplicatorClient

func (m *MockClientFactory) GetReplicatorClient() (replicator.TChanReplicator, error)

GetReplicatorClient is a mock of the corresponding common. routine

func (*MockClientFactory) GetThriftStoreClient

func (m *MockClientFactory) GetThriftStoreClient(replica string, id string) (store.TChanBStore, error)

GetThriftStoreClient is a mock of the corresponding common. routine

func (*MockClientFactory) GetThriftStoreClientUUID

func (m *MockClientFactory) GetThriftStoreClientUUID(storeUUID string, contextID string) (store.TChanBStore, string, error)

GetThriftStoreClientUUID is a mock of the corresponding common. routine

func (*MockClientFactory) ReleaseThriftStoreClient

func (m *MockClientFactory) ReleaseThriftStoreClient(id string)

ReleaseThriftStoreClient is a mock of the corresponding common. routine

type MockHTTPResponseWriter

type MockHTTPResponseWriter struct {
	mock.Mock
}

MockHTTPResponseWriter is the mock of http.ResponseWriter interface

func (*MockHTTPResponseWriter) Header

func (_m *MockHTTPResponseWriter) Header() http.Header

Header is the mock for corresponding method on ResponseWriter

func (*MockHTTPResponseWriter) Write

func (_m *MockHTTPResponseWriter) Write(_a0 []byte) (int, error)

Write is the mock for corresponding method on ResponseWriter

func (*MockHTTPResponseWriter) WriteHeader

func (_m *MockHTTPResponseWriter) WriteHeader(_a0 int)

WriteHeader is the mock for corresponding method on ResponseWriter

type MockTokenBucket

type MockTokenBucket struct {
	mock.Mock
}

func (*MockTokenBucket) Consume

func (m *MockTokenBucket) Consume(count int, timeout time.Duration) bool

Consume is the mock for corresponding method on TokenBucket

func (*MockTokenBucket) TryConsume

func (m *MockTokenBucket) TryConsume(count int) (bool, time.Duration)

TryConsume is the mock for corresponding method on TokenBucket

type MockWSConnector

type MockWSConnector struct {
	mock.Mock
}

MockWSConnector is the mock of common.WSConnector interface

func (*MockWSConnector) AcceptAppendStream

func (_m *MockWSConnector) AcceptAppendStream(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenAppendStreamInCall, error)

AcceptAppendStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) AcceptConsumerStream

func (_m *MockWSConnector) AcceptConsumerStream(w http.ResponseWriter, r *http.Request) (serverStream.BOutOpenConsumerStreamInCall, error)

AcceptConsumerStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) AcceptPublisherStream

func (_m *MockWSConnector) AcceptPublisherStream(w http.ResponseWriter, r *http.Request) (serverStream.BInOpenPublisherStreamInCall, error)

AcceptPublisherStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) AcceptReadStream

func (_m *MockWSConnector) AcceptReadStream(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenReadStreamInCall, error)

AcceptReadStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) AcceptReplicationReadStream

func (_m *MockWSConnector) AcceptReplicationReadStream(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenReadStreamInCall, error)

AcceptReplicationReadStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) AcceptReplicationRemoteReadStream

func (_m *MockWSConnector) AcceptReplicationRemoteReadStream(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenReadStreamInCall, error)

AcceptReplicationRemoteReadStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) OpenAppendStream

func (_m *MockWSConnector) OpenAppendStream(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenAppendStreamOutCall, error)

OpenAppendStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) OpenConsumerStream

func (_m *MockWSConnector) OpenConsumerStream(hostPort string, requestHeader http.Header) (clientStream.BOutOpenConsumerStreamOutCall, error)

OpenConsumerStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) OpenPublisherStream

func (_m *MockWSConnector) OpenPublisherStream(hostPort string, requestHeader http.Header) (clientStream.BInOpenPublisherStreamOutCall, error)

OpenPublisherStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) OpenReadStream

func (_m *MockWSConnector) OpenReadStream(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenReadStreamOutCall, error)

OpenReadStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) OpenReplicationReadStream

func (_m *MockWSConnector) OpenReplicationReadStream(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenReadStreamOutCall, error)

OpenReplicationReadStream is the mock for corresponding method on WSConnector

func (*MockWSConnector) OpenReplicationRemoteReadStream

func (_m *MockWSConnector) OpenReplicationRemoteReadStream(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenReadStreamOutCall, error)

OpenReplicationRemoteReadStream is the mock for corresponding method on WSConnector