pubsubmock

Documentation

Index

• type Client
  • func New() *Client
  • func (c *Client) Publish(ctx context.Context, backtestID uint, evt event.Interface) error
  • func (c *Client) Subscribe(ctx context.Context, backtestID uint) (pubsub.Subscriber, error)
• type TickSubscriber
  • func (ps *TickSubscriber) Channel() <-chan event.Interface
  • func (ps *TickSubscriber) Close() error

Types

type Client

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

func New

func New() *Client

func (*Client) Publish

func (c *Client) Publish(ctx context.Context, backtestID uint, evt event.Interface) error

func (*Client) Subscribe

func (c *Client) Subscribe(ctx context.Context, backtestID uint) (pubsub.Subscriber, error)

type TickSubscriber

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

func (*TickSubscriber) Channel

func (ps *TickSubscriber) Channel() <-chan event.Interface

func (*TickSubscriber) Close

func (ps *TickSubscriber) Close() error