Documentation
¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
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
Source Files
Click to show internal directories.
Click to hide internal directories.