outputhost

Documentation

Index

• type OutClientImpl
  • func NewClient(instanceID int, hostAddr string) (*OutClientImpl, error)
  • func (s *OutClientImpl) Close()
  • 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) UnloadConsumerGroups

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

UnloadConsumerGroups unloads the CG from the outputhost