events

type Config struct {
	Timeout time.Duration
}

type Event struct {
	Type    string          `json:"type"`
	Payload json.RawMessage `json:"payload"`
}

type EventWrapper struct {
	ID    string
	Event Event
	Ack   func() bool
	Nack  func() bool
}

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

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