dynamodb

Documentation

Index

• type EventMirroringToDynamoDBService
  • func NewEventMirroringToDynamoDBService(awsRegion string, awsURL string, awsAccessKeyID string, ...) *EventMirroringToDynamoDBService
  • func (s *EventMirroringToDynamoDBService) Acknowledge(ctx *context.Context, event *event.Event) *types.Error
  • func (s *EventMirroringToDynamoDBService) Consume(ctx *context.Context, topicName string) (*event.Event, *types.Error)
  • func (s *EventMirroringToDynamoDBService) IsExist(ctx *context.Context, _event *event.Event) bool
  • func (s *EventMirroringToDynamoDBService) Publish(ctx *context.Context, params *event.PublishEventParams) *types.Error

Types

type EventMirroringToDynamoDBService

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

EventMirroringToDynamoDBService implementor of event mirroring service which stores to dynamo db

func NewEventMirroringToDynamoDBService

func NewEventMirroringToDynamoDBService(
	awsRegion string,
	awsURL string,
	awsAccessKeyID string,
	awsSecretAccessKey string,
	awsToken string,
	tableName string,
	serviceName string,
	pubsubTopics map[string]*pubsub.Topic,
	notifier notifier.Notifier,
) *EventMirroringToDynamoDBService

NewEventMirroringToDynamoDBService build new event mirroring to dynamodb services object

func (*EventMirroringToDynamoDBService) Acknowledge

func (s *EventMirroringToDynamoDBService) Acknowledge(ctx *context.Context, event *event.Event) *types.Error

Acknowledge acknowledge / remove event from dynamodb by idempotentId

func (*EventMirroringToDynamoDBService) Consume

func (s *EventMirroringToDynamoDBService) Consume(ctx *context.Context, topicName string) (*event.Event, *types.Error)

Consume consume event from dynamodb with return the first event from dynamodb

func (*EventMirroringToDynamoDBService) IsExist

func (s *EventMirroringToDynamoDBService) IsExist(ctx *context.Context, _event *event.Event) bool

IsExist check whether the event is exist in dynamodb

func (*EventMirroringToDynamoDBService) Publish

func (s *EventMirroringToDynamoDBService) Publish(ctx *context.Context, params *event.PublishEventParams) *types.Error

Publish publish event with mirroring in dynamodb