cherami

package
v0.0.0-...-f9f87ea Latest Latest
Warning

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

Go to latest
Published: Jan 1, 2017 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBInOpenPublisherStreamOutCall

type MockBInOpenPublisherStreamOutCall struct {
	mock.Mock
}

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

func (*MockBInOpenPublisherStreamOutCall) Done

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

func (*MockBInOpenPublisherStreamOutCall) Flush

Flush flushes all written arguments. routinee

func (*MockBInOpenPublisherStreamOutCall) Read

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

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

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

func (*MockBOutOpenConsumerStreamOutCall) Flush

Flush flushes all written arguments. routinee

func (*MockBOutOpenConsumerStreamOutCall) Read

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

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 (*MockTChanBInClient) PutMessageBatch

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 (*MockTChanBOutClient) ReceiveMessageBatch

Jump to

Keyboard shortcuts

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