entrypoint

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

type AWSProvider interface {
	SNS() SNSAPI
	SQS() SQSAPI
	EventBridge() EventBridgeAPI

	Region() string
	Credentials() aws.CredentialsProvider
}

type Config struct {
	AppName         string `env:"APP_NAME" `
	EnvironmentName string `env:"ENVIRONMENT_NAME" `
	SidecarVersion  string // set from main

	ServerConfig httpserver.ServerConfig
	WorkerConfig queueworker.WorkerConfig
	ProxyConfig  pgproxy.ProxyConfig

	OutboxConfig      pgoutbox.OutboxConfig
	BridgeConfig      bridge.BridgeConfig
	EventBridgeConfig eventbridge.EventBridgeConfig

	ServiceEndpoints []string `env:"SERVICE_ENDPOINT" default:""`
}

type EventBridgeAPI interface {
	PutEvents(ctx context.Context, params *eventbridge.PutEventsInput, optFns ...func(*eventbridge.Options)) (*eventbridge.PutEventsOutput, error)
}

type Publisher interface {
	pgoutbox.Batcher
	queueworker.Publisher
}

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

type SNSAPI interface {
	PublishBatch(ctx context.Context, params *sns.PublishBatchInput, optFns ...func(*sns.Options)) (*sns.PublishBatchOutput, error)
	Publish(ctx context.Context, params *sns.PublishInput, optFns ...func(*sns.Options)) (*sns.PublishOutput, error)
}

type SQSAPI interface {
	ReceiveMessage(ctx context.Context, input *sqs.ReceiveMessageInput, opts ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)
	DeleteMessage(ctx context.Context, input *sqs.DeleteMessageInput, opts ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)
}