eventmesh

Documentation

Index

• type Sender
  • func NewSender(target string, c *http.Client, l *logger.Logger) *Sender
  • func (s *Sender) Checker() *health.ConfigurableChecker
  • func (s *Sender) NewRequestWithTarget(ctx context.Context, target string) (*http.Request, error)
  • func (s *Sender) Send(ctx context.Context, event *cev2event.Event) sender.PublishError
  • func (s *Sender) URL() string

Types

type Sender

type Sender struct {
	Client *http.Client
	Target string
	// contains filtered or unexported fields
}

Sender is responsible for sending messages over HTTP.

func NewSender

func NewSender(target string, c *http.Client, l *logger.Logger) *Sender

NewSender returns a new Sender instance with the given target and client.

func (*Sender) Checker

func (s *Sender) Checker() *health.ConfigurableChecker

func (*Sender) NewRequestWithTarget

func (s *Sender) NewRequestWithTarget(ctx context.Context, target string) (*http.Request, error)

NewRequestWithTarget returns a new HTTP POST request with the given context and target.

func (*Sender) Send

func (s *Sender) Send(ctx context.Context, event *cev2event.Event) sender.PublishError

func (*Sender) URL

func (s *Sender) URL() string