log

package

v0.0.0-...-af0f53c Latest Latest Go to latest Published: Mar 19, 2023 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

KafkaCommandLog is a struct that provides a mechanism to log saga commands sent through Kafka.

func NewKafkaCommandLog(writer *kafka.Writer, reader *kafka.Reader) *KafkaCommandLog

func (k *KafkaCommandLog) Commit(ctx context.Context, c command.Command) error

Commit commits the specified command to Kafka.

func (k *KafkaCommandLog) Read(ctx context.Context) (command.Command, error)

Read reads the next command from Kafka.

func (k *KafkaCommandLog) Write(ctx context.Context, c command.Command) error

Write writes the specified command to Kafka topic with partitioning by saga id.