runreveal

Documentation

Index

• type Option
  • func WithBatchSize(size int) Option
  • func WithFlushFrequency(t time.Duration) Option
  • func WithHTTPClient(httpc *http.Client) Option
  • func WithWebhookURL(url string) Option
• type RunReveal
  • func New(opts ...Option) *RunReveal
  • func (r *RunReveal) Flush(ctx context.Context, msgs []kawa.Message[types.Event]) error
  • func (r *RunReveal) Run(ctx context.Context) error
  • func (r *RunReveal) Send(ctx context.Context, ack func(), msgs ...kawa.Message[types.Event]) error

Types

type Option

type Option func(*RunReveal)

func WithBatchSize

func WithBatchSize(size int) Option

func WithFlushFrequency

func WithFlushFrequency(t time.Duration) Option

func WithHTTPClient

func WithHTTPClient(httpc *http.Client) Option

func WithWebhookURL

func WithWebhookURL(url string) Option

type RunReveal

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

func New

func New(opts ...Option) *RunReveal

func (*RunReveal) Flush

func (r *RunReveal) Flush(ctx context.Context, msgs []kawa.Message[types.Event]) error

Flush sends the given messages of type kawa.Message[type.Event] to the RunReveal api

func (*RunReveal) Run

func (r *RunReveal) Run(ctx context.Context) error

func (*RunReveal) Send

func (r *RunReveal) Send(ctx context.Context, ack func(), msgs ...kawa.Message[types.Event]) error