storehost

Documentation

Index

• type StoreClientImpl
  • func NewClient(storeUUID, hostAddr string) (*StoreClientImpl, error)
  • func (s *StoreClientImpl) Close()
  • func (s *StoreClientImpl) ReadMessages(req *store.ReadMessagesRequest) (*store.ReadMessagesResult_, error)

Types

type StoreClientImpl

type StoreClientImpl struct {
	// contains filtered or unexported fields
}

StoreClientImpl is a storehost cherami tchannel client

func NewClient

func NewClient(storeUUID, hostAddr string) (*StoreClientImpl, error)

NewClient returns a new instance of cherami tchannel client

func (*StoreClientImpl) Close

func (s *StoreClientImpl) Close()

Close closes the client

func (*StoreClientImpl) ReadMessages

func (s *StoreClientImpl) ReadMessages(req *store.ReadMessagesRequest) (*store.ReadMessagesResult_, error)

ReadMessages reads a sequence of messages from the store