event

type Context struct {
	ProcessID   string `json:"processID"`
	TaskID      string `json:"taskID"`
	EventType   string `json:"eventType"`
	Service     string `json:"service"`
	Method      string `json:"method"`
	TimeTakenMs int    `json:"timeTakenMs"`
}

type Event[T any] struct {
	Context   *Context               `json:"context"`
	CreatedAt time.Time              `json:"createdAt"`
	Metadata  map[string]interface{} `json:"metadata"`
	Data      T                      `json:"data"`
}

type Listener[T any] struct {
	// contains filtered or unexported fields
}

type Option func(s *Service)

type Publisher[T any] struct {
	// contains filtered or unexported fields
}

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