dispatcher

type AsyncCallback func(payload []byte, err error)

type Config struct {
	CallTimeout            time.Duration
	WriteTimeout           time.Duration
	PingInterval           time.Duration
	PongWait               time.Duration
	SerializeOutboundCalls bool
	OutboundQueueSize      int
	// AsyncQueueSize bounds the per-connection FIFO queue used by DoCallAsync when
	// SerializeOutboundCalls is set; enqueuing beyond it returns ocppj.ErrQueueFull.
	AsyncQueueSize        int
	MaxConcurrentHandlers int64
	// GlobalHandlerLimiter, when non-nil, bounds the total number of inbound
	// handlers running concurrently across all connections that share it. It is
	// acquired in addition to the per-connection MaxConcurrentHandlers budget.
	// nil disables the global cap. The same *semaphore.Weighted must be shared
	// by every connection for the limit to be server-wide.
	GlobalHandlerLimiter *semaphore.Weighted
	Logger               *slog.Logger
	Metrics              MetricsHook
	Tracer               observability.Tracer
	// SchemaValidate optionally validates a payload for the given version.
	// nil disables validation. SchemaMode controls how returned errors are handled.
	SchemaValidate func(version ocppj.Version, action, kind string, payload []byte) error
	// SchemaValidateLenient validates a payload in lenient mode. It returns the
	// possibly enum-normalized payload to dispatch, the soft-violation keywords
	// seen, and a non-nil error only for hard violations. Used only when
	// SchemaMode == SchemaModeLenient. Returns primitives so the dispatcher stays
	// decoupled from core/schema.
	SchemaValidateLenient func(version ocppj.Version, action, kind string, payload []byte) (out []byte, soft []string, err error)
	SchemaMode            SchemaMode
}

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

type ConnMetadata struct {
	RemoteAddr    string
	RequestHeader http.Header
	TLS           *tls.ConnectionState
}

type HandlerFunc func(ctx context.Context, c *Conn, payload []byte) ([]byte, error)

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

type MetricsHook interface {
	ConnectionOpened()
	ConnectionClosed()
	CallStarted(action, direction string)
	CallCompleted(action, direction string, dur time.Duration, status string)
	PendingDelta(delta int)
}

type Op int

type Role int

type SchemaMode int