Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TokenRpcConsumer ¶
type TokenRpcConsumer struct {
// contains filtered or unexported fields
}
func NewTokenRpcConsumer ¶
func NewTokenRpcConsumer( rpcClient *common.RpcClient, cfg *config.Dendrite, ) *TokenRpcConsumer
func (*TokenRpcConsumer) Clean ¶
func (s *TokenRpcConsumer) Clean()
func (*TokenRpcConsumer) GetCB ¶
func (s *TokenRpcConsumer) GetCB() common.MsgHandlerWithContext
func (*TokenRpcConsumer) GetTopic ¶
func (s *TokenRpcConsumer) GetTopic() string
func (*TokenRpcConsumer) Start ¶
func (s *TokenRpcConsumer) Start() error
Click to show internal directories.
Click to hide internal directories.