consumers

package
v0.0.0-...-9835270 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FilterTokenCB

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

func NewFilterTokenConsumer

func NewFilterTokenConsumer(
	client *common.RpcClient,
	tokenFilter *filter.SimpleFilter,
) *FilterTokenCB

func (*FilterTokenCB) Clean

func (f *FilterTokenCB) Clean()

func (*FilterTokenCB) GetCB

func (*FilterTokenCB) GetTopic

func (f *FilterTokenCB) GetTopic() string

func (*FilterTokenCB) Start

func (f *FilterTokenCB) Start() error

type VerifyToken

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

type VerifyTokenCB

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

func NewVerifyTokenConsumer

func NewVerifyTokenConsumer(
	client *common.RpcClient,
	tokenFilter *filter.SimpleFilter,
	cache service.Cache,
	cfg *config.Dendrite,
) *VerifyTokenCB

func (*VerifyTokenCB) Clean

func (f *VerifyTokenCB) Clean()

func (*VerifyTokenCB) GetCB

func (*VerifyTokenCB) GetTopic

func (f *VerifyTokenCB) GetTopic() string

func (*VerifyTokenCB) Start

func (f *VerifyTokenCB) Start() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL