pubsub

type Consumer interface {

	// Process receives messages for furthe processing.
	Process(messageData string) error
}

type ExampleMessage struct {

	// Value is content of this test message.
	Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
	// Timestamp for testing.
	Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	// contains filtered or unexported fields
}

type LambdaHandler interface {

	// Receive is a AWS lambda event handler to consumer SNS messages.
	Receive(ctx context.Context, snsEvent events.SNSEvent)

	// Subsribe is used to register message consumer for specific topics.
	Subsribe(topicArn string, consumer Consumer)
}

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

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

type ObjectId string

type Persistence interface {

	// Upload a message to a persitence location. Returns an object id if passed message has been persisted successful.
	Upload(topic string, message proto.Message) (*ObjectId, error)

	// Download can be used to retrieve a message by given object id.
	Download(id *ObjectId) (proto.Message, error)

	// Type returns type of used persistence layer.
	Type() string
}

type Publisher interface {

	// Send will publish a message.
	Send(topicArn string, message proto.Message) error
}

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