Versions in this module Expand all Collapse all v0 v0.2.1 Oct 9, 2026 v0.2.0 Oct 8, 2026 Changes in this version + const ProtocolMajor + const ProtocolMinor + type Cancel struct + ID string + Reason CancelReason + type CancelReason int + const CancelCallerGone + const CancelDeadlineExceeded + const CancelShutdown + const CancelUnspecified + type Client struct + func New(transport Transport, config Config) *Client + func (c *Client) Draining(deadline time.Time) + func (c *Client) Grant(additional uint32) + func (c *Client) Serve(ctx context.Context) error + type Config struct + Concurrency int + Limits func() map[string]int + Reconcile func(blueprint []HandlerConfig) ([]string, error) + Resolve func(tag string) (layer.Next, bool) + SDKVersion string + Tags []string + type CreditGrant struct + Additional uint32 + type DialConfig struct + FallbackEnabled bool + FallbackPort int + RetryFor time.Duration + Socket string + func DialConfigFromEnv() DialConfig + func (c DialConfig) Target() (string, error) + type Drain struct + Deadline time.Time + type Draining struct + Deadline time.Time + type FromRuntime struct + Cancel *Cancel + Config *RuntimeConfig + Dispatch *handler.Event + Drain *Drain + ReadyAck *ReadyAck + WsAck *WsSendAck + type HandlerConfig struct + HandlerName string + HandlerTag string + PublishedName string + Timeout time.Duration + TracingEnabled bool + type HandlerLimit struct + HandlerTag string + MaxConcurrent uint32 + type Outbound struct + IsBinary bool + type ProtocolVersion struct + Major uint32 + Minor uint32 + func (v ProtocolVersion) String() string + type ProtocolVersionError struct + Declared ProtocolVersion + Served ProtocolVersion + func (e *ProtocolVersionError) Error() string + type Ready struct + HandlerTags []string + InitialCredit uint32 + Limits []HandlerLimit + Protocol ProtocolVersion + SDKVersion string + type ReadyAck struct + Accepted bool + Reason RefusedReason + UnhandledTags []string + UnknownTags []string + type RefusedReason int + const RefusedProtocolVersion + const RefusedTagMismatch + const RefusedUnspecified + type Result struct + CreditGrant uint32 + Outcome *handler.Result + type RuntimeConfig struct + Handlers []HandlerConfig + MetricsEnabled bool + Protocol ProtocolVersion + TracingEnabled bool + func (c *RuntimeConfig) Tags() []string + type TagMismatchError struct + Unhandled []string + Unknown []string + func (e *TagMismatchError) Error() string + type ToRuntime struct + Credit *CreditGrant + Draining *Draining + Ready *Ready + Result *Result + WsSend *WsSend + type Transport interface + Close func() error + Recv func() (*FromRuntime, error) + Send func(*ToRuntime) error + func Dial(ctx context.Context, config DialConfig) (Transport, error) + type WsSend struct + CorrelationID string + Messages []Outbound + type WsSendAck struct + CorrelationID string + Failures []handler.SendFailure + Success bool
Go to main page