events

type Encoder interface {
	Encode(v interface{}) ([]byte, error)
	Decode(data []byte) (interface{}, error)
}

type Event struct {
	Subject  string            `json:"subject"`            // The exact subject name
	Data     interface{}       `json:"data"`               // The actual event data
	Metadata map[string]string `json:"metadata,omitempty"` // Optional metadata like timestamps, IDs, etc.
}

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

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

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

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

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