websocket

Documentation

Index

• type ConsumerT
  • func (c *ConsumerT) HandleMessage(msg *nsq.Message) error
• type PubSubAPI
  • func NewPubSubAPI(nsqHost string, nsqInterval time.Duration, log *log.Logger) *PubSubAPI
  • func (pubsub *PubSubAPI) NewToken(ctx context.Context, address string) (*rpc.Subscription, error)
  • func (pubsub *PubSubAPI) PingPong(ctx context.Context, targetRpcId rpc.ID) (*rpc.Subscription, error)
• type Type

Types

type ConsumerT

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

func (*ConsumerT) HandleMessage

func (c *ConsumerT) HandleMessage(msg *nsq.Message) error

type PubSubAPI

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

func NewPubSubAPI

func NewPubSubAPI(nsqHost string, nsqInterval time.Duration, log *log.Logger) *PubSubAPI

func (*PubSubAPI) NewToken

func (pubsub *PubSubAPI) NewToken(ctx context.Context, address string) (*rpc.Subscription, error)

func (*PubSubAPI) PingPong

func (pubsub *PubSubAPI) PingPong(ctx context.Context, targetRpcId rpc.ID) (*rpc.Subscription, error)

type Type

type Type byte

Type determines the kind of filter and is used to put the filter in to the correct bucket when added.

const (
	// UnknownSubscription indicates an unknown subscription type
	UnknownSubscription Type = iota

	// 发现新token
	NewErc20

	// LastSubscription keeps track of the last index
	LastIndexSubscription
)