pubsub

type CommitFunc func(message *Message) (bool, bool)

type Message struct {
	SchemaID  int
	Topic     string
	Partition int
	Offset    int64
	Key       string
	Value     string
	Headers   map[string]string
	Event     *eventhub.Event
}

type PublishOptions struct {
	Topic     string    // default: reads topic from config, else empty string
	Partition int       // default: 0
	Timestamp time.Time // default: current timestamp
}

type PublisherSubscriber interface {
	/*
		PublishEventWithOptions publishes message to the pubsub(kafka) configured.

			Ability to provide additional options as described in PublishOptions struct

			returns error if publish encounters a failure
	*/
	PublishEventWithOptions(key string, value interface{}, headers map[string]string, options *PublishOptions) error

	/*
		PublishEvent publishes message to the pubsub(kafka) configured.

			Information like topic is read from config, timestamp is set to current time
			other fields like offset and partition are set to it's default value
			if desire to overwrite these fields, refer PublishEventWithOptions() method above

			returns error if publish encounters a failure
	*/
	PublishEvent(string, interface{}, map[string]string) error

	/*
		Subscribe read messages from the pubsub(kafka) configured.

			If multiple topics are provided in the environment or
			in kafka config while creating the consumer, reads messages from multiple topics
			reads only one message at a time. If desire to read multiple messages
			call Subscribe in a for loop

			returns error if subscribe encounters a failure
			on success returns the message received in the Message struct format
	*/
	Subscribe() (*Message, error)

	/*
			SubscribeWithCommit read messages from the pubsub(kafka) configured.

				calls the CommitFunc after subscribing message from kafka and based on
		        the return values decides whether to commit message and consume another message
	*/
	SubscribeWithCommit(CommitFunc) (*Message, error)

	/*
		Bind converts message received from Subscribe to the specified target
			returns error, if messages doesn't adhere to the target structure
	*/
	Bind(message []byte, target interface{}) error

	CommitOffset(offsets TopicPartition)
	/*
		Ping checks for the health of the pubsub
			returns an error if the pubsub is down
	*/
	Ping() error

	// HealthCheck returns the health of the PubSub
	HealthCheck() types.Health

	// IsSet can be used to check if PubSub is initialized with a valid connection or not
	IsSet() bool
}

type PublisherSubscriberV2 interface {
	PublisherSubscriber

	// Pause will be used to pause the processing in kafka/sarama
	Pause() error

	// resume will be used to resume all the consumer groups in kafka/sarama
	Resume() error
}

type TopicPartition struct {
	Topic     string
	Partition int
	Offset    int64
	Metadata  *string
	Error     error
}