server

Documentation

Index

• Variables
• func Handle(hdlr server.Handler) error
• func NewHandler(hdlr interface{}, opts ...server.HandlerOption) server.Handler
• func NewSubscriber(topic string, hdlr interface{}, opts ...server.SubscriberOption) server.Subscriber
• func Subscribe(sub server.Subscriber) error

Variables

var DefaultServer server.Server = grpc.NewServer()

DefaultServer for the service

Functions

func Handle

func Handle(hdlr server.Handler) error

Register a handler

func NewHandler

func NewHandler(hdlr interface{}, opts ...server.HandlerOption) server.Handler

Create a new handler

func NewSubscriber

func NewSubscriber(topic string, hdlr interface{}, opts ...server.SubscriberOption) server.Subscriber

Create a new subscriber

func Subscribe

func Subscribe(sub server.Subscriber) error

Register a subscriber