eurus

package module

Go to main page

Versions in this module

v2

v2.1.0

Jul 24, 2026

Changes in this version

+ const ContextKeyRouteDescriptor

+ const ContextKeyServiceDescriptor

+ const ContextKeyServiceDescriptors

+ var ErrNoRouteMetadata = errors.New("eurus: route has no metadata")

type Gateway

+ func (g *Gateway) DescriptorMiddleware() velaros.HandlerFunc

type GatewayServiceIndexer

+ func (r *GatewayServiceIndexer) Resolve(path string) (*ServiceDescriptor, *RouteDescriptor, bool)

type RouteDescriptor

+ Metadata any

+ func RouteDescriptorFromContext(ctx *velaros.Context) *RouteDescriptor

+ func (r *RouteDescriptor) UnmarshalMetadata(into any) error

type ServiceDescriptor

+ func ServiceDescriptorFromContext(ctx *velaros.Context) *ServiceDescriptor

+ func ServiceDescriptorsFromContext(ctx *velaros.Context) []*ServiceDescriptor

v2.0.0

Jul 24, 2026

Changes in this version

+ var ClosedSocketTTL = 30 * time.Second

+ var ConnectionMailboxSize = 64

+ var ErrGatewayAlreadyConnected = errors.New("eurus: gateway already connected")

+ var ErrNoTransport = errors.New("eurus: no transport provided")

+ var ErrServiceAlreadyListening = errors.New("eurus: service already listening")

+ var ErrSlowConsumer = errors.New("eurus: slow consumer")

+ var GatewayAnnounceInterval = time.Duration(8+rand.IntN(2)) * time.Second

+ var GatewaySendTimeout = 30 * time.Second

+ var HeartbeatInterval = 5 * time.Second

+ var ServicePruneInterval = 10 * time.Second

+ type Connection struct

+ func NewConnection(transport Transport, gatewayID, socketID string, info *velaros.ConnectionInfo, ...) *Connection

+ func (c *Connection) Close(status velaros.Status, reason string) error

+ func (c *Connection) GatewayID() string

+ func (c *Connection) HandleClose(status velaros.Status, reason string)

+ func (c *Connection) HandleMessage(msg *velaros.SocketMessage)

+ func (c *Connection) Read(readCtx context.Context) (*velaros.SocketMessage, error)

+ func (c *Connection) Write(ctx context.Context, msg *velaros.SocketMessage) error

+ type ConnectionMessage struct

+ Data []byte

+ MessageType velaros.MessageType

+ type Gateway struct

+ AnnounceInterval time.Duration

+ ID string

+ Name string

+ SendTimeout time.Duration

+ Transport Transport

+ func NewGateway(name string, transport Transport) *Gateway

+ func (g *Gateway) CanHandle(ctx *velaros.Context) bool

+ func (g *Gateway) CanServePath(path string) bool

+ func (g *Gateway) Close() error

+ func (g *Gateway) Connect(ctx context.Context) error

+ func (g *Gateway) Handle(ctx *velaros.Context)

+ func (g *Gateway) HandleClose(ctx *velaros.Context)

+ func (g *Gateway) Ready() <-chan struct{}

+ type GatewayDescriptor struct

+ Name string

+ ServiceDescriptors []*ServiceDescriptor

+ type GatewayServiceIndexer struct

+ func NewGatewayServiceIndexer() *GatewayServiceIndexer

+ func (r *GatewayServiceIndexer) Close()

+ func (r *GatewayServiceIndexer) FreshServiceDescriptors(threshold time.Duration) []*ServiceDescriptor

+ func (r *GatewayServiceIndexer) IsClosed() bool

+ func (r *GatewayServiceIndexer) MapSocket(serviceName, socketID string) (string, bool, error)

+ func (r *GatewayServiceIndexer) PruneStaleServices(threshold time.Duration) ([]string, []string)

+ func (r *GatewayServiceIndexer) ResolveService(path string) (string, bool)

+ func (r *GatewayServiceIndexer) ServiceDescriptors() []*ServiceDescriptor

+ func (r *GatewayServiceIndexer) SetServiceDescriptor(descriptor *ServiceDescriptor) error

+ func (r *GatewayServiceIndexer) SocketIDsByServiceInstance() map[string][]string

+ func (r *GatewayServiceIndexer) UnmapSocket(socketID string)

+ func (r *GatewayServiceIndexer) UnsetService(id string) error

+ type RouteDescriptor struct

+ Pattern *velaros.Pattern

+ func NewRouteDescriptor(patternStr string) (*RouteDescriptor, error)

+ func (r *RouteDescriptor) MarshalMsgpack() ([]byte, error)

+ func (r *RouteDescriptor) UnmarshalMsgpack(data []byte) error

+ type Service struct

+ ClosedSocketTTL time.Duration

+ GatewayNames []string

+ HeartbeatInterval time.Duration

+ ID string

+ MailboxSize int

+ Name string

+ PruneInterval time.Duration

+ RouteDescriptors []*RouteDescriptor

+ Router *velaros.Router

+ Transport Transport

+ func NewService(name string, transport Transport, handler any) *Service

+ func (s *Service) Close() error

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

+ func (s *Service) Ready() <-chan struct{}

+ type ServiceDescriptor struct

+ GatewayNames []string

+ ID string

+ LastSeenAt *time.Time

+ Name string

+ RouteDescriptors []*RouteDescriptor

+ type Subscription interface

+ Serve func(ctx context.Context) error

+ type SubscriptionFunc func(ctx context.Context) error

+ func (f SubscriptionFunc) Serve(ctx context.Context) error

+ type Transport interface

+ AnnounceGateway func(gatewayDescriptor *GatewayDescriptor) error

+ AnnounceService func(serviceDescriptor *ServiceDescriptor) error

+ ClosedSocket func(socketID string, status velaros.Status, reason string) error

+ HeartbeatSockets func(gatewayID string, serviceID string, socketIDs []string) (dead []string, err error)

+ MessageGateway func(gatewayID string, socketID string, msg *velaros.SocketMessage) error

+ MessageService func(serviceID, gatewayID, socketID string, connInfo *velaros.ConnectionInfo, ...) error

+ SubscribeGatewayAnnouncements func(ctx context.Context, handler func(gatewayDescriptor *GatewayDescriptor)) (Subscription, error)

+ SubscribeGatewayMessages func(ctx context.Context, gatewayID string, ...) (Subscription, error)

+ SubscribeServiceAnnouncements func(ctx context.Context, handler func(serviceDescriptor *ServiceDescriptor)) (Subscription, error)

+ SubscribeServiceMessages func(ctx context.Context, serviceID string, ...) (Subscription, error)

+ SubscribeSocketClosures func(ctx context.Context, ...) (Subscription, error)

+ SubscribeSocketHeartbeats func(ctx context.Context, gatewayID string, ...) (Subscription, error)

Other modules containing this package

github.com/RobertWHurst/eurus

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL