messaging

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

type Message struct {
	ID          string    `json:"message_id"`
	Time        time.Time `json:"message_time"`
	TimeUsec    int64     `json:"message_time_microseconds"`
	StreamName  string    `json:"stream_name"`
	Key         string    `json:"message_key"`
	ContentType string    `json:"content_type"`
	Data        []byte    `json:"data"`
}

type Reader interface {
	Read(ctx context.Context, task ReaderTask) error
}

type ReaderTask struct {
	Stream  string
	GroupID string
	Handler SubscriberFunc
}

type SubscriberFunc func(ctx context.Context, message Message) error

type Writer interface {
	Write(ctx context.Context, msgs []Message) error
}