submitter

Documentation

Index

• type Submitter
  • func NewSubmitter(logger *slog.Logger, client gen.MetricsClient) *Submitter
  • func (s *Submitter) Await()
  • func (s *Submitter) Chan() chan<- *gen.Result
  • func (s *Submitter) Run(ctx context.Context) (err error)

Types

type Submitter

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

func NewSubmitter

func NewSubmitter(logger *slog.Logger, client gen.MetricsClient) *Submitter

NewSubmitter creates a new submitter object.

func (*Submitter) Await

func (s *Submitter) Await()

Await signals the goroutine running Run that no more metrics will be sent on the channel. Then it waits for that goroutine to submit them (with retries).

func (*Submitter) Chan

func (s *Submitter) Chan() chan<- *gen.Result

Chan returns a channel on which metrics can be provided to the submitter.

func (*Submitter) Run

func (s *Submitter) Run(ctx context.Context) (err error)

Run accepts metrics on the channel and submits them to the client passed to constructor until Await is called.