storehost

Documentation

Index

• type MockBStoreOpenAppendStreamOutCall
  • func (m *MockBStoreOpenAppendStreamOutCall) Done() error
  • func (m *MockBStoreOpenAppendStreamOutCall) Flush() error
  • func (m *MockBStoreOpenAppendStreamOutCall) Read() (*store.AppendMessageAck, error)
  • func (m *MockBStoreOpenAppendStreamOutCall) ResponseHeaders() (map[string]string, error)
  • func (m *MockBStoreOpenAppendStreamOutCall) Write(msg *store.AppendMessage) error
• type MockBStoreOpenReadStreamOutCall
  • func (m *MockBStoreOpenReadStreamOutCall) Done() error
  • func (m *MockBStoreOpenReadStreamOutCall) Flush() error
  • func (m *MockBStoreOpenReadStreamOutCall) Read() (*store.ReadMessageContent, error)
  • func (m *MockBStoreOpenReadStreamOutCall) ResponseHeaders() (map[string]string, error)
  • func (m *MockBStoreOpenReadStreamOutCall) Write(msg *cherami.ControlFlow) error
• type MockStoreHost
  • func (m *MockStoreHost) GetAddressFromTimestamp(ctx thrift.Context, getAddressRequest *store.GetAddressFromTimestampRequest) (*store.GetAddressFromTimestampResult_, error)
  • func (m *MockStoreHost) GetExtentInfo(ctx thrift.Context, extentInfoRequest *store.GetExtentInfoRequest) (*store.ExtentInfo, error)
  • func (m *MockStoreHost) OpenAppendStream(ctx thrift.Context) (serverStream.BStoreOpenAppendStreamOutCall, error)
  • func (m *MockStoreHost) OpenReadStream(ctx thrift.Context) (serverStream.BStoreOpenReadStreamOutCall, error)
  • func (m *MockStoreHost) PurgeMessages(ctx thrift.Context, purgeMessagesRequest *store.PurgeMessagesRequest) (*store.PurgeMessagesResult_, error)
  • func (m *MockStoreHost) ReadMessages(ctx thrift.Context, readMessagesRequest *store.ReadMessagesRequest) (*store.ReadMessagesResult_, error)
  • func (m *MockStoreHost) RemoteReplicateExtent(ctx thrift.Context, request *store.RemoteReplicateExtentRequest) error
  • func (m *MockStoreHost) ReplicateExtent(ctx thrift.Context, replicateExtentRequest *store.ReplicateExtentRequest) error
  • func (m *MockStoreHost) SealExtent(ctx thrift.Context, sealRequest *store.SealExtentRequest) error

Types

type MockBStoreOpenAppendStreamOutCall

type MockBStoreOpenAppendStreamOutCall struct {
	mock.Mock
}

MockBStoreOpenAppendStreamOutCall is the mock of store.BStoreOpenAppendStreamOutCall this can be used by all clients of storehost to write messages for example: inputhost will use this to test its write path

func (*MockBStoreOpenAppendStreamOutCall) Done

func (m *MockBStoreOpenAppendStreamOutCall) Done() error

Done is the mock of the corresponding store. method

func (*MockBStoreOpenAppendStreamOutCall) Flush

func (m *MockBStoreOpenAppendStreamOutCall) Flush() error

Flush is the mock of the corresponding store. method

func (*MockBStoreOpenAppendStreamOutCall) Read

func (m *MockBStoreOpenAppendStreamOutCall) Read() (*store.AppendMessageAck, error)

Read is the mock of the corresponding store. method

func (*MockBStoreOpenAppendStreamOutCall) ResponseHeaders

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

ResponseHeaders is the mock of the corresponding store. method

func (*MockBStoreOpenAppendStreamOutCall) Write

func (m *MockBStoreOpenAppendStreamOutCall) Write(msg *store.AppendMessage) error

Write is the mock of the corresponding store. method

type MockBStoreOpenReadStreamOutCall

type MockBStoreOpenReadStreamOutCall struct {
	mock.Mock
}

MockBStoreOpenReadStreamOutCall is the mock of store.BStoreOpenReadStreamOutCall this can be used by all clients of storehost to write messages for example: inputhost will use this to test its write path

func (*MockBStoreOpenReadStreamOutCall) Done

func (m *MockBStoreOpenReadStreamOutCall) Done() error

Done is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCall) Flush

func (m *MockBStoreOpenReadStreamOutCall) Flush() error

Flush is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCall) Read

func (m *MockBStoreOpenReadStreamOutCall) Read() (*store.ReadMessageContent, error)

Read is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCall) ResponseHeaders

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

ResponseHeaders is the mock of the corresponding store. method

func (*MockBStoreOpenReadStreamOutCall) Write

func (m *MockBStoreOpenReadStreamOutCall) Write(msg *cherami.ControlFlow) error

Write is the mock of the corresponding store. method

type MockStoreHost

type MockStoreHost struct {
	mock.Mock
}

MockStoreHost is a mock of the storehost used for testing

func (*MockStoreHost) GetAddressFromTimestamp

func (m *MockStoreHost) GetAddressFromTimestamp(ctx thrift.Context, getAddressRequest *store.GetAddressFromTimestampRequest) (*store.GetAddressFromTimestampResult_, error)

GetAddressFromTimestamp is a mock of the corresponding storehost routinee

func (*MockStoreHost) GetExtentInfo

func (m *MockStoreHost) GetExtentInfo(ctx thrift.Context, extentInfoRequest *store.GetExtentInfoRequest) (*store.ExtentInfo, error)

GetExtentInfo is a mock of the corresponding storehost routinee

func (*MockStoreHost) OpenAppendStream

func (m *MockStoreHost) OpenAppendStream(ctx thrift.Context) (serverStream.BStoreOpenAppendStreamOutCall, error)

OpenAppendStream is a mock of the corresponding storehost routinee

func (*MockStoreHost) OpenReadStream

func (m *MockStoreHost) OpenReadStream(ctx thrift.Context) (serverStream.BStoreOpenReadStreamOutCall, error)

OpenReadStream is a mock of the corresponding storehost routinee

func (*MockStoreHost) PurgeMessages

func (m *MockStoreHost) PurgeMessages(ctx thrift.Context, purgeMessagesRequest *store.PurgeMessagesRequest) (*store.PurgeMessagesResult_, error)

PurgeMessages is a mock of the corresponding storehost routine

func (*MockStoreHost) ReadMessages

func (m *MockStoreHost) ReadMessages(ctx thrift.Context, readMessagesRequest *store.ReadMessagesRequest) (*store.ReadMessagesResult_, error)

ReadMessages is a mock of the corresponding storehost routine

func (*MockStoreHost) RemoteReplicateExtent

func (m *MockStoreHost) RemoteReplicateExtent(ctx thrift.Context, request *store.RemoteReplicateExtentRequest) error

RemoteReplicateExtent is a mock of the corresponding storehost routine

func (*MockStoreHost) ReplicateExtent

func (m *MockStoreHost) ReplicateExtent(ctx thrift.Context, replicateExtentRequest *store.ReplicateExtentRequest) error

ReplicateExtent is a mock of the corresponding storehost routine

func (*MockStoreHost) SealExtent

func (m *MockStoreHost) SealExtent(ctx thrift.Context, sealRequest *store.SealExtentRequest) error

SealExtent is a mock of the corresponding storehost routinee