storehost

Documentation

Index

• type StoreClientImpl
  • func NewClient(storeUUID, hostAddr string) (*StoreClientImpl, error)
  • func (s *StoreClientImpl) Close()
  • func (s *StoreClientImpl) GetAddressFromTimestamp(req *store.GetAddressFromTimestampRequest) (*store.GetAddressFromTimestampResult_, error)
  • func (s *StoreClientImpl) ListExtents() (*store.ListExtentsResult_, error)
  • func (s *StoreClientImpl) PurgeMessages(req *store.PurgeMessagesRequest) (*store.PurgeMessagesResult_, error)
  • func (s *StoreClientImpl) ReadMessages(req *store.ReadMessagesRequest) (*store.ReadMessagesResult_, error)
  • func (s *StoreClientImpl) SealExtent(req *store.SealExtentRequest) 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) GetAddressFromTimestamp

func (s *StoreClientImpl) GetAddressFromTimestamp(req *store.GetAddressFromTimestampRequest) (*store.GetAddressFromTimestampResult_, error)

GetAddressFromTimestamp queries store for the address corresponding to the given timestamp

func (*StoreClientImpl) ListExtents

func (s *StoreClientImpl) ListExtents() (*store.ListExtentsResult_, error)

ListExtents lists the extents on the specified store

func (*StoreClientImpl) PurgeMessages

func (s *StoreClientImpl) PurgeMessages(req *store.PurgeMessagesRequest) (*store.PurgeMessagesResult_, error)

PurgeMessages seals an extent on the specified store

func (*StoreClientImpl) ReadMessages

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

ReadMessages reads a sequence of messages from the store

func (*StoreClientImpl) SealExtent

func (s *StoreClientImpl) SealExtent(req *store.SealExtentRequest) error

SealExtent seals an extent on the specified store