sqs

Documentation

Index

• func Module() fx.Option
• func NewEvent(c giawsclientsqs.Client) repository.Event
• type Client
  • func NewClient(c sqs.Client) *Client
  • func (p *Client) Publish(ctx context.Context, events []*v2.Event) error

Functions

func Module

func Module() fx.Option

Module loads the sqs module providing an initialized client.

The module is only loaded once.

func NewEvent

func NewEvent(c giawsclientsqs.Client) repository.Event

NewEvent returns a initialized client

Types

type Client

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

Client represents a sqs client.

func NewClient

func NewClient(c sqs.Client) *Client

NewClient creates a new sqs client.

func (*Client) Publish

func (p *Client) Publish(ctx context.Context, events []*v2.Event) error

Publish publishes an event slice.