dynamodb

package
v1.0.34 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 30, 2025 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

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

func NewClient

func NewClient(cfg *config.Configuration) (*Client, error)

func (*Client) DB

func (c *Client) DB() *dynamodb.Client

type DynamoEvent

type DynamoEvent struct {
	PK                 string                 `dynamodbav:"pk"` // TenantID
	SK                 string                 `dynamodbav:"sk"` // EventID
	EnvironmentID      string                 `dynamodbav:"environment_id"`
	EventName          string                 `dynamodbav:"event_name"`
	Properties         map[string]interface{} `dynamodbav:"properties"`
	Timestamp          time.Time              `dynamodbav:"timestamp"`
	Source             string                 `dynamodbav:"source"`
	IngestedAt         time.Time              `dynamodbav:"ingested_at"`
	CustomerID         string                 `dynamodbav:"customer_id"`
	ExternalCustomerID string                 `dynamodbav:"external_customer_id"`
}

type EventPublisher

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

func NewEventPublisher

func NewEventPublisher(client *Client, cfg *config.Configuration, logger *logger.Logger) *EventPublisher

func (*EventPublisher) Publish

func (p *EventPublisher) Publish(ctx context.Context, event *events.Event) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL