bus

type Bus interface {
	Publish(ctx context.Context, subject Subject, data []byte) error
	Subscribe(ctx context.Context, subject Subject) (Subscription, error)
	EnsureStream(ctx context.Context, cfg StreamConfig) error
	Consume(ctx context.Context, cfg ConsumeConfig) (Consumer, error)
	Close() error
}

type ConsumeConfig struct {
	Stream  string
	Durable string
	Subject Subject
}

type Consumer interface {
	C() <-chan Message
	Close() error
}

type Message struct {
	Subject Subject
	Data    []byte
	// contains filtered or unexported fields
}

type StreamConfig struct {
	Name     string
	Subjects []Subject
}

type Subject string

type Subscription interface {
	C() <-chan Message
	Unsubscribe() error
}