server

Jul 9, 2020

Changes in this version

+ func Init(opt ...Option)

+ func String() string

+ type Handler interface

+ Handler func() interface{}

+ Name func() string

+ Options func() HandlerOptions

+ type HandlerOption func(*HandlerOptions)

+ type HandlerOptions struct

+ Internal bool

+ Metadata map[string]map[string]string

+ type Option func(*Options)

+ type Options struct

+ Addr string

+ Context context.Context

+ Id string

+ Metadata map[string]string

+ Name string

+ Network string

+ On bool

+ Once sync.Once

+ ReadTimeout string

+ Timeout string

+ Version string

+ WriteTimeout string

+ type Server interface

+ Init func(...Option) error

+ Options func() Options

+ Start func() error

+ Stop func(ctx context.Context) error

+ String func() string

+ var DefaultServer Server = newGinServer()

+ var NewServer func(...Option) Server = newGinServer

+ type Subscriber interface

+ Options func() SubscriberOptions

+ Subscriber func() interface{}

+ Topic func() string

+ type SubscriberOption func(*SubscriberOptions)

+ type SubscriberOptions struct

+ AutoAck bool

+ Context context.Context

+ Internal bool

+ Queue string