graph

May 8, 2021

Changes in this version

+ func InitPubSub(client *pubsub.PubSub) error

Mar 22, 2021

Changes in this version

+ func LinkedTx(m *data.MemPoolTx, params ...interface{}) bool

Mar 13, 2021

Changes in this version

+ func CheckFromAddress(m *data.MemPoolTx, params ...interface{}) bool

+ func CheckToAddress(m *data.MemPoolTx, params ...interface{}) bool

+ func InitParentContext(ctx context.Context)

+ func InitRedisClient(client *redis.Client) error

+ func ListenToMessages(ctx context.Context, pubsub *redis.PubSub, topics []string, ...)

+ func NoCriteria(*data.MemPoolTx, ...interface{}) bool

+ func SubscribeToMemPool(ctx context.Context) (*redis.PubSub, error)

+ func SubscribeToPendingPool(ctx context.Context) (*redis.PubSub, error)

+ func SubscribeToPendingTxEntry(ctx context.Context) (*redis.PubSub, error)

+ func SubscribeToPendingTxExit(ctx context.Context) (*redis.PubSub, error)

+ func SubscribeToQueuedPool(ctx context.Context) (*redis.PubSub, error)

+ func SubscribeToQueuedTxEntry(ctx context.Context) (*redis.PubSub, error)

+ func SubscribeToQueuedTxExit(ctx context.Context) (*redis.PubSub, error)

+ func SubscribeToTopic(ctx context.Context, topic ...string) (*redis.PubSub, error)

+ func UnmarshalPubSubMessage(message []byte) *data.MemPoolTx

+ func UnsubscribeFromTopic(ctx context.Context, pubsub *redis.PubSub, topic string)

+ type PublishingCriteria func(*data.MemPoolTx, ...interface{}) bool

type Resolver

+ func (r *Resolver) Subscription() generated.SubscriptionResolver

Mar 8, 2021

Changes in this version

+ func InitMemPool(pool *data.MemPool) error

+ type Resolver struct

+ func (r *Resolver) Query() generated.QueryResolver