outgoing

Documentation

Index

• type Client
  • func NewMultiplexClient(clients []Client) Client
• type ClientTemplate
  • func NewClientTemplate(ctx context.Context, cfg *config.OutgoingWebhookConfig, ...) (ClientTemplate, error)

Types

type Client

type Client interface {
	Send(ctx context.Context, msg domain.Message) error

	// Shutdown this client.
	// This method wait until all in-flight request ends.
	Close(ctx context.Context)

	String() string
}

Client is an outgoing-webhook client.

func NewMultiplexClient

func NewMultiplexClient(clients []Client) Client

NewMultiplexClient wraps given clients as a single client

type ClientTemplate

type ClientTemplate interface {
	NewClient(tplEnv domain.TemplateStringEnv) (Client, error)
	Close()

	GetFileDescriptorPressure() int // estimated max usage of file descriptors
}

ClientTemplate is factory object to make Client

func NewClientTemplate

func NewClientTemplate(ctx context.Context, cfg *config.OutgoingWebhookConfig, telemetry *telemetry.Telemetry, sentry sentry.Sentry) (ClientTemplate, error)

NewClientTemplate returns ClientTemplate instalce