messaging

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

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

type Message interface {
	String() string

	Context() context.Context
	Topic() string
	Data() []byte
	Respond(message []byte) error
	Nak() error
	Ack() error
}

type Messager interface {
	Subscribe(topic string, handler func(msg Message)) error
	Publish(ctx context.Context, topic string, message []byte) error
}

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

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

type NATSOptions struct {
	URL string `json:"url"`
}