runtime

Nov 26, 2025

Changes in this version

+ func NewEventID() string

+ func RegisterCloudEventsHandler(s *Service, reg CloudEventsHandlerRegistration) error

+ type CloudEventsHandlerRegistration struct

+ EventType string

+ Handler EventHandler

+ MaxAttempts int

+ Name string

+ type DLQMetrics struct

+ func NewDLQMetrics(registerer prometheus.Registerer) *DLQMetrics

+ func (m *DLQMetrics) GetSnapshot() DLQMetricsSnapshot

+ func (m *DLQMetrics) GetTopicMetrics(topic string) *DLQTopicMetrics

+ func (m *DLQMetrics) RecordMessageReplayed(topic string)

+ func (m *DLQMetrics) RecordMessageToDLQ(topic, handler string, retryCount int, messageAge time.Duration)

+ func (m *DLQMetrics) RecordMessagesPurged(topic string, count int64)

+ func (m *DLQMetrics) Register() error

+ func (m *DLQMetrics) Reset()

+ func (m *DLQMetrics) SetCurrentCount(topic string, count uint64)

+ type DLQMetricsSnapshot struct

+ CollectedAt time.Time

+ TopicMetrics map[string]*DLQTopicMetrics

+ TotalMessages uint64

+ TotalPurged uint64

+ TotalReplayed uint64

+ type DLQTopicMetrics struct

+ AvgRetryCount float64

+ LastUpdatedAt time.Time

+ MessagesCurrent uint64

+ MessagesPurged uint64

+ MessagesReceived uint64

+ MessagesReplayed uint64

+ NewestMessageAt time.Time

+ OldestMessageAt time.Time

+ type EventContext struct

+ Event ce.Event

+ Logger interface{ ... }

+ Publisher *Service

+ RawData json.RawMessage

+ func (ec *EventContext) Publish(ctx context.Context, eventType, source string, data any) error

+ func (ec *EventContext) UnmarshalData(v any) error

+ type EventHandler func(ctx context.Context, evt ce.Event) error

+ type JobContext struct

+ Context context.Context

+ Duration time.Duration

+ HandlerName string

+ MessageUUID string

+ Metadata message.Metadata

+ RetryCount int

+ StartedAt time.Time

+ Topic string

+ type JobHooks struct

+ OnJobDone func(ctx JobContext)

+ OnJobError func(ctx JobContext, err error)

+ OnJobStart func(ctx JobContext)

+ func AlertingHooks(alertFunc func(ctx JobContext, err error)) JobHooks

+ func LoggingHooks(logger interface{ ... }) JobHooks

+ func MetricsHooks(onStart, onDone, onError func(handlerName, topic string)) JobHooks

+ func (h JobHooks) Merge(other JobHooks) JobHooks

type MiddlewareRegistration

+ func JobHooksMiddleware(hooks JobHooks) MiddlewareRegistration

+ type PublishOption func(*publishOptions)

+ func WithCorrelationID(correlationID string) PublishOption

+ func WithDataContentType(contentType string) PublishOption

+ func WithDataSchema(schema string) PublishOption

+ func WithExtension(key string, value any) PublishOption

+ func WithMaxAttempts(max int) PublishOption

+ func WithSubject(subject string) PublishOption

+ func WithTracing(traceID, parentID string) PublishOption

type Service

+ func TryNewService(conf *configpkg.Config, log loggingpkg.ServiceLogger, ctx context.Context, ...) (*Service, error)

+ func (s *Service) ConsumeEvents(eventType string, handler EventHandler) error

+ func (s *Service) GetTransportCapabilities() transportpkg.Capabilities

+ func (s *Service) Publish(ctx context.Context, topic string, msgs ...*message.Message) error

+ func (s *Service) PublishData(ctx context.Context, eventType, source string, data any, opts ...PublishOption) error

+ func (s *Service) PublishDataAfter(ctx context.Context, eventType, source string, data any, delay time.Duration, ...) error

+ func (s *Service) PublishEvent(ctx context.Context, evt ce.Event) error

+ func (s *Service) PublishEventAfter(ctx context.Context, evt ce.Event, delay time.Duration) error

+ func (s *Service) Stop()

Nov 24, 2025

Changes in this version

+ const DependencyStatusDegraded

+ const DependencyStatusHealthy

+ const DependencyStatusUnknown

+ type BacklogMetrics struct

+ EstimatedLagMillis int64

+ InFlight uint64

+ LastQueueDepth int64

+ MaxInFlight uint64

+ type DependencyHealth struct

+ Details string

+ LastChecked time.Time

+ Name string

+ Status string

+ type ErrorBreakdown struct

+ Downstream uint64

+ LastError string

+ Other uint64

+ Transport uint64

+ Validation uint64

+ func (e *ErrorBreakdown) Record(category ErrorCategory, err error)

+ type ErrorCategory string

+ const ErrorCategoryDownstream

+ const ErrorCategoryNone

+ const ErrorCategoryOther

+ const ErrorCategoryTransport

+ const ErrorCategoryValidation

+ type ErrorClassifier func(error) ErrorCategory

type HandlerStats

+ Backlog BacklogMetrics

+ Dependencies []DependencyHealth

+ Errors ErrorBreakdown

+ Latency LatencyMetrics

+ Resource ResourceUsage

+ Throughput ThroughputMetrics

+ type LatencyMetrics struct

+ AverageNs int64

+ LastNs int64

+ P50Ns int64

+ P95Ns int64

+ P99Ns int64

+ SampleSize int

+ type ResourceUsage struct

+ CPUPercent float64

+ Goroutines int

+ MemoryBytes uint64

type ServiceDependencies

+ ErrorClassifier ErrorClassifier

+ type ThroughputMetrics struct

+ CurrentRPS float64

+ MessagesInWindow uint64

+ TotalMessages uint64

+ WindowSeconds float64

Nov 24, 2025

Changes in this version

+ type HandlerInfo struct

+ ConsumeQueue string

+ Name string

+ PublishQueue string

+ Stats *HandlerStats

+ type HandlerStats struct

+ LastProcessedAt time.Time

+ MessagesFailed uint64

+ MessagesProcessed uint64

+ TotalProcessingTime int64

+ func (h *HandlerStats) MarshalJSON() ([]byte, error)

type RetryMiddlewareConfig

+ RetryIf func(error) bool

type Service

+ func (s *Service) RegisterHTTPHandler(port int, pattern string, handler http.Handler)

+ func (s *Service) StartWebUIServer()

Nov 24, 2025

Changes in this version

type MiddlewareRegistration

+ func MetricsMiddleware() MiddlewareRegistration

Nov 21, 2025

Changes in this version

+ func MustProtoMessage[T proto.Message]() T

+ func NewMessageFromProto(event proto.Message, metadata metadatapkg.Metadata) (*message.Message, error)

+ func NewProtoMessage[T proto.Message]() (T, error)

+ func PublishProto(ctx context.Context, publisher message.Publisher, topic string, ...) error

+ func RegisterJSONHandler[T any, O any](svc *Service, cfg handlerpkg.JSONHandlerRegistration[T, O]) error

+ func RegisterMessageHandler(svc *Service, cfg MessageHandlerRegistration) error

+ func RegisterProtoHandler[T proto.Message](svc *Service, cfg handlerpkg.ProtoHandlerRegistration[T]) error

+ type MessageHandlerRegistration struct

+ ConsumeQueue string

+ Handler message.HandlerFunc

+ Name string

+ PublishQueue string

+ Publisher message.Publisher

+ Subscriber message.Subscriber

+ type MiddlewareBuilder func(*Service) (message.HandlerMiddleware, error)

+ type MiddlewareRegistration struct

+ Builder MiddlewareBuilder

+ Middleware message.HandlerMiddleware

+ Name string

+ func CorrelationIDMiddleware() MiddlewareRegistration

+ func DefaultMiddlewares() []MiddlewareRegistration

+ func LogMessagesMiddleware(logger loggingpkg.ServiceLogger) MiddlewareRegistration

+ func OutboxMiddleware() MiddlewareRegistration

+ func PoisonQueueMiddleware(filter func(error) bool) MiddlewareRegistration

+ func ProtoValidateMiddleware() MiddlewareRegistration

+ func RecovererMiddleware() MiddlewareRegistration

+ func RetryMiddleware(cfg RetryMiddlewareConfig) MiddlewareRegistration

+ func TracerMiddleware() MiddlewareRegistration

+ type OutboxStore interface

+ StoreOutgoingMessage func(ctx context.Context, eventType, uuid, payload string) error

+ type Producer interface

+ PublishProto func(ctx context.Context, topic string, event proto.Message, ...) error

+ type ProtoValidator interface

+ Validate func(value any) error

+ type RetryMiddlewareConfig struct

+ InitialInterval time.Duration

+ MaxInterval time.Duration

+ MaxRetries int

+ type Service struct

+ Conf *configpkg.Config

+ Logger loggingpkg.ServiceLogger

+ func NewService(conf *configpkg.Config, log loggingpkg.ServiceLogger, ctx context.Context, ...) *Service

+ func (s *Service) PublishProto(ctx context.Context, topic string, event proto.Message, ...) error

+ func (s *Service) RegisterMiddleware(cfg MiddlewareRegistration) error

+ func (s *Service) RegisterProtoMessage(msg proto.Message)

+ func (s *Service) Start(ctx context.Context) error

+ type ServiceDependencies struct

+ DisableDefaultMiddlewares bool

+ Middlewares []MiddlewareRegistration

+ Outbox OutboxStore

+ TransportFactory transportpkg.Factory

+ Validator ProtoValidator

+ type UnprocessableEventError struct

+ func (e *UnprocessableEventError) Error() string