outputhost

Documentation

Index

• type OutClientImpl
  • func NewClient(instanceID int, hostAddr string) (*OutClientImpl, error)
  • func (s *OutClientImpl) Close()
  • func (s *OutClientImpl) ListLoadedConsumerGroups() (*admin.ListConsumerGroupsResult_, error)
  • func (s *OutClientImpl) ReadCgState(req *admin.ReadConsumerGroupStateRequest) (*admin.ReadConsumerGroupStateResult_, error)
  • func (s *OutClientImpl) UnloadConsumerGroups(req *admin.UnloadConsumerGroupsRequest) error

Types

type OutClientImpl

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

OutClientImpl is a outputhost cherami tchannel client

func NewClient

func NewClient(instanceID int, hostAddr string) (*OutClientImpl, error)

NewClient returns a new instance of cherami tchannel client

func (*OutClientImpl) Close

func (s *OutClientImpl) Close()

Close closes the client

func (*OutClientImpl) ListLoadedConsumerGroups

func (s *OutClientImpl) ListLoadedConsumerGroups() (*admin.ListConsumerGroupsResult_, error)

ListLoadedConsumerGroups lists all the loaded cgs from the outputhost

func (*OutClientImpl) ReadCgState

func (s *OutClientImpl) ReadCgState(req *admin.ReadConsumerGroupStateRequest) (*admin.ReadConsumerGroupStateResult_, error)

ReadCgState returns consumer group state inside output host

func (*OutClientImpl) UnloadConsumerGroups

func (s *OutClientImpl) UnloadConsumerGroups(req *admin.UnloadConsumerGroupsRequest) error

UnloadConsumerGroups unloads the CG from the outputhost