messaging

type EventName string

type KafkaMessage struct {
	EventName string `json:"EventName"`
	Key       string `json:"Key"`
}

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

type Message interface {
	GetEvent() (EventName, error)
	GetBucket() (string, error)
	GetItem() (string, error)
}

type MessageProvider interface {
	ReceiveMessage(ctx context.Context) (Message, error)
	Close(ctx context.Context) error
}

type MessageProviderBuilder interface {
	GetMessageProvider(config MessageProviderConfig) (MessageProvider, error)
}

type MessageProviderConfig struct {
	Queue    string
	Endpoint string
	Provider string
	Region   string
}

type SqsBucket struct {
	Name string `json:"name"`
}

type SqsMessage struct {
	Records []SqsRecord `json:"Records"`
}

type SqsObject struct {
	Key string `json:"key"`
}

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

type SqsRecord struct {
	EventName string `json:"eventName"`
	S3        SqsS3  `json:"s3"`
}

type SqsS3 struct {
	Object SqsObject `json:"object"`
	Bucket SqsBucket `json:"bucket"`
}