pubsub

Documentation

Index

• func WithContext(parent context.Context, pubsub Client) context.Context
• type Client
  • func FromContext(ctx context.Context) Client
• type Subscriber

Functions

func WithContext

func WithContext(parent context.Context, pubsub Client) context.Context

Types

type Client

type Client interface {
	Publish(ctx context.Context, backtestID uint, event event.Interface) error
	Subscribe(ctx context.Context, backtestID uint) (Subscriber, error)
}

func FromContext

func FromContext(ctx context.Context) Client

type Subscriber

type Subscriber interface {
	Channel() <-chan event.Interface
	Close() error
}