cherami

Documentation

Index

• type MockBInOpenPublisherStreamOutCall
  • func (m *MockBInOpenPublisherStreamOutCall) Done() error
  • func (m *MockBInOpenPublisherStreamOutCall) Flush() error
  • func (m *MockBInOpenPublisherStreamOutCall) Read() (*cherami.InputHostCommand, error)
  • func (m *MockBInOpenPublisherStreamOutCall) ResponseHeaders() (map[string]string, error)
  • func (m *MockBInOpenPublisherStreamOutCall) Write(arg *cherami.PutMessage) error
• type MockBOutOpenConsumerStreamOutCall
  • func (m *MockBOutOpenConsumerStreamOutCall) Done() error
  • func (m *MockBOutOpenConsumerStreamOutCall) Flush() error
  • func (m *MockBOutOpenConsumerStreamOutCall) Read() (*cherami.OutputHostCommand, error)
  • func (m *MockBOutOpenConsumerStreamOutCall) ResponseHeaders() (map[string]string, error)
  • func (m *MockBOutOpenConsumerStreamOutCall) Write(arg *cherami.ControlFlow) error
• type MockTChanBInClient
  • func (m *MockTChanBInClient) OpenPublisherStream(ctx thrift.Context) (stream.BInOpenPublisherStreamOutCall, error)
  • func (m *MockTChanBInClient) PutMessageBatch(ctx thrift.Context, request *cherami.PutMessageBatchRequest) (*cherami.PutMessageBatchResult_, error)
• type MockTChanBOutClient
  • func (m *MockTChanBOutClient) AckMessages(ctx thrift.Context, ackRequest *cherami.AckMessagesRequest) error
  • func (m *MockTChanBOutClient) OpenConsumerStream(ctx thrift.Context) (stream.BOutOpenConsumerStreamOutCall, error)
  • func (m *MockTChanBOutClient) OpenStreamingConsumerStream(ctx thrift.Context) (stream.BOutOpenStreamingConsumerStreamOutCall, error)
  • func (m *MockTChanBOutClient) ReceiveMessageBatch(ctx thrift.Context, request *cherami.ReceiveMessageBatchRequest) (*cherami.ReceiveMessageBatchResult_, error)
  • func (m *MockTChanBOutClient) SetConsumedMessages(ctx thrift.Context, request *cherami.SetConsumedMessagesRequest) error
• type MockWSConnector
  • func (_m *MockWSConnector) OpenConsumerStream(hostPort string, requestHeader http.Header) (stream.BOutOpenConsumerStreamOutCall, error)
  • func (_m *MockWSConnector) OpenPublisherStream(hostPort string, requestHeader http.Header) (stream.BInOpenPublisherStreamOutCall, error)

Types

type MockBInOpenPublisherStreamOutCall

type MockBInOpenPublisherStreamOutCall struct {
	mock.Mock
}

MockBInOpenPublisherStreamOutCall is a mock for BInOpenPublisherStreamOutCall used for unit testing of cherami client

func (*MockBInOpenPublisherStreamOutCall) Done

func (m *MockBInOpenPublisherStreamOutCall) Done() error

Done closes the request stream and should be called after all arguments have been written. routinee

func (*MockBInOpenPublisherStreamOutCall) Flush

func (m *MockBInOpenPublisherStreamOutCall) Flush() error

Flush flushes all written arguments. routinee

func (*MockBInOpenPublisherStreamOutCall) Read

func (m *MockBInOpenPublisherStreamOutCall) Read() (*cherami.InputHostCommand, error)

Read returns the next result, if any is available. If there are no more results left, it will return io.EOF. routinee

func (*MockBInOpenPublisherStreamOutCall) ResponseHeaders

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

ResponseHeaders returns the response headers sent from the server. This will block until server headers have been received. routinee

func (*MockBInOpenPublisherStreamOutCall) Write

func (m *MockBInOpenPublisherStreamOutCall) Write(arg *cherami.PutMessage) error

Write writes an argument to the request stream. The written items may not be sent till Flush or Done is called. routinee

type MockBOutOpenConsumerStreamOutCall

type MockBOutOpenConsumerStreamOutCall struct {
	mock.Mock
}

MockBOutOpenConsumerStreamOutCall is a mock for BOutOpenConsumerStreamOutCall used for unit testing of cherami client

func (*MockBOutOpenConsumerStreamOutCall) Done

func (m *MockBOutOpenConsumerStreamOutCall) Done() error

Done closes the request stream and should be called after all arguments have been written. routinee

func (*MockBOutOpenConsumerStreamOutCall) Flush

func (m *MockBOutOpenConsumerStreamOutCall) Flush() error

Flush flushes all written arguments. routinee

func (*MockBOutOpenConsumerStreamOutCall) Read

func (m *MockBOutOpenConsumerStreamOutCall) Read() (*cherami.OutputHostCommand, error)

Read returns the next result, if any is available. If there are no more results left, it will return io.EOF. routinee

func (*MockBOutOpenConsumerStreamOutCall) ResponseHeaders

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

ResponseHeaders returns the response headers sent from the server. This will block until server headers have been received. routinee

func (*MockBOutOpenConsumerStreamOutCall) Write

func (m *MockBOutOpenConsumerStreamOutCall) Write(arg *cherami.ControlFlow) error

Write writes an argument to the request stream. The written items may not be sent till Flush or Done is called. routinee

type MockTChanBInClient

type MockTChanBInClient struct {
	mock.Mock
}

MockTChanBInClient is a mock for TChanBInClient used for unit testing of cherami client

func (*MockTChanBInClient) OpenPublisherStream

func (m *MockTChanBInClient) OpenPublisherStream(ctx thrift.Context) (stream.BInOpenPublisherStreamOutCall, error)

func (*MockTChanBInClient) PutMessageBatch

func (m *MockTChanBInClient) PutMessageBatch(ctx thrift.Context, request *cherami.PutMessageBatchRequest) (*cherami.PutMessageBatchResult_, error)

type MockTChanBOutClient

type MockTChanBOutClient struct {
	mock.Mock
}

MockBOutOpenConsumerStreamOutCall is a mock for BOutOpenConsumerStreamOutCall used for unit testing of cherami client

func (*MockTChanBOutClient) AckMessages

func (m *MockTChanBOutClient) AckMessages(ctx thrift.Context, ackRequest *cherami.AckMessagesRequest) error

func (*MockTChanBOutClient) OpenConsumerStream

func (m *MockTChanBOutClient) OpenConsumerStream(ctx thrift.Context) (stream.BOutOpenConsumerStreamOutCall, error)

func (*MockTChanBOutClient) OpenStreamingConsumerStream

func (m *MockTChanBOutClient) OpenStreamingConsumerStream(ctx thrift.Context) (stream.BOutOpenStreamingConsumerStreamOutCall, error)

func (*MockTChanBOutClient) ReceiveMessageBatch

func (m *MockTChanBOutClient) ReceiveMessageBatch(ctx thrift.Context, request *cherami.ReceiveMessageBatchRequest) (*cherami.ReceiveMessageBatchResult_, error)

func (*MockTChanBOutClient) SetConsumedMessages

func (m *MockTChanBOutClient) SetConsumedMessages(ctx thrift.Context, request *cherami.SetConsumedMessagesRequest) error

type MockWSConnector

type MockWSConnector struct {
	mock.Mock
}

MockWSConnector is a mock for WSConnector used for unit testing

func (*MockWSConnector) OpenConsumerStream

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

func (*MockWSConnector) OpenPublisherStream

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