types

type Close func()

type Consumer interface {
	// Subscribe creates a new topic subscription that will receive
	// messages consumed by the consumer of the given topic. This method
	// will return a message channel and a close function.
	// Once a message is successfully processed should the next message be called.
	Subscribe(topics ...Topic) (subscription <-chan *Message, err error)

	// Unsubscribe unsubscribes the given channel subscription from the given topic.
	// A boolean is returned that represents if the channel successfully got unsubscribed.
	Unsubscribe(subscription <-chan *Message) error

	// Close closes the kafka consumer, all topic subscriptions and event channels.
	Close() error
}

type Dialect interface {
	// Consumer returns the dialect consumer
	Consumer() Consumer

	// Producer returns the dialect producer
	Producer() Producer

	// Healthy when called should it check if the dialect's consumer/producer are healthy and
	// up and running. This method could be called to check if the service is up and running.
	// The user should implement the health check
	Healthy() bool

	// Opens the given dialect to start accepting incoming and outgoing connections.
	Open(topics []Topic) error

	// Close awaits till the consumer(s) and producer(s) of the given dialect are closed.
	// If an error is returned is the closing aborted and the error returned to the user.
	Close() error
}

type Handler interface {
	Handle(*Message, Writer)
}

type HandlerFunc func(*Message, Writer)

type Message struct {
	ID        string    `json:"id"`
	Topic     Topic     `json:"topic"`
	Action    string    `json:"action"`
	Version   Version   `json:"version"`
	Data      []byte    `json:"data"`
	Key       []byte    `json:"key"`
	Timestamp time.Time `json:"timestamp"`
	// contains filtered or unexported fields
}

type MessageType int8

type Next func()

type Producer interface {
	// Publish produces a message to the given topic
	Publish(message *Message) error

	// Close closes the producer
	Close() error
}

type Resolved int

type Topic interface {
	// Dialect returns the topic Dialect
	Dialect() Dialect
	// Type returns the topic type
	Type() MessageType
	// Mode returns the topic mode
	Mode() TopicMode
	// HasMode checks if the topic represents the given topic type
	HasMode(TopicMode) bool
	// Name returns the topic name
	Name() string
}

type TopicMode int8

type Version int8

type Writer interface {
	// Event creates and produces a new event to the assigned group.
	Event(action string, version int8, key []byte, data []byte) (*Message, error)

	// Error produces a new error event to the assigned group.
	Error(action string, err error) (*Message, error)

	// Command produces a new command to the assigned group.
	Command(action string, version int8, key []byte, data []byte) (*Message, error)
}