reportclient

Documentation

Index

• func InitReportClient(lc fx.Lifecycle, reportClient *Client)
• type Client
  • func NewReportClient(cnf queueing.MasterConfig, repo reportrepo.Repo, ...) *Client
  • func (a *Client) Notify()
  • func (a *Client) Publish()
  • func (a *Client) ReportClient()
  • func (a *Client) Subscribe() (uuid.UUID, <-chan struct{})
  • func (a *Client) Unsubscribe(uid uuid.UUID)

Functions

func InitReportClient

func InitReportClient(lc fx.Lifecycle, reportClient *Client)

Types

type Client

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

func NewReportClient

func NewReportClient(cnf queueing.MasterConfig, repo reportrepo.Repo, pubsub queue.MasterStreamPubSub) *Client

func (*Client) Notify

func (a *Client) Notify()

func (*Client) Publish

func (a *Client) Publish()

func (*Client) ReportClient

func (a *Client) ReportClient()

func (*Client) Subscribe

func (a *Client) Subscribe() (uuid.UUID, <-chan struct{})

func (*Client) Unsubscribe

func (a *Client) Unsubscribe(uid uuid.UUID)