server

Apr 23, 2024

Changes in this version

+ type FuncHandler func(ctx context.Context, req Request, rsp interface{}) error

+ type HookHandler func(next FuncHandler) FuncHandler

Apr 22, 2024

Changes in this version

+ type FuncBatchSubHandler func(ctxs []context.Context, ms []Message) error

+ type FuncSubHandler func(ctx context.Context, ms Message) error

+ type HookBatchSubHandler func(next FuncBatchSubHandler) FuncBatchSubHandler

+ type HookSubHandler func(next FuncSubHandler) FuncSubHandler

type Option

+ func Hooks(h ...options.Hook) Option

Mar 4, 2024

Changes in this version

+ var DefaultGracefulTimeout = 5 * time.Second

type Option

+ func GracefulTimeout(td time.Duration) Option

type Options

+ GracefulTimeout time.Duration

Apr 2, 2023

Changes in this version

type Options

+ Hooks options.Hooks

Feb 13, 2023

Changes in this version

type HandlerOption

+ func SetHandlerOption(k, v interface{}) HandlerOption

Jan 10, 2022

Changes in this version

type Stream

+ RecvMsg func(msg interface{}) error

+ SendMsg func(msg interface{}) error

Oct 2, 2021

Changes in this version

+ var DefaultAddress = "127.0.0.1:0"

+ var DefaultCodecs = map[string]codec.Codec

+ var DefaultDeregisterFunc = func(svc *register.Service, config Options) error

+ var DefaultID = id.Must()

+ var DefaultMaxMsgRecvSize = 1024 * 1024 * 4

+ var DefaultMaxMsgSendSize = 1024 * 1024 * 4

+ var DefaultMaxMsgSize = 1024 * 1024 * 4

+ var DefaultName = "server"

+ var DefaultNamespace = "micro"

+ var DefaultRegisterCheck = func(context.Context) error

+ var DefaultRegisterFunc = func(svc *register.Service, config Options) error

+ var DefaultRegisterInterval = time.Second * 30

+ var DefaultRegisterTTL = time.Second * 90

+ var DefaultVersion = "latest"

+ func NewContext(ctx context.Context, s Server) context.Context

+ func NewRegisterService(s Server) (*register.Service, error)

+ func ValidateSubscriber(sub Subscriber) error

+ type BatchSubscriberFunc func(ctxs []context.Context, msgs []Message) error

+ type BatchSubscriberWrapper func(BatchSubscriberFunc) BatchSubscriberFunc

+ type Error struct

+ func NewError(id string) *Error

+ func (e *Error) BadGateway(format string, a ...interface{}) error

+ func (e *Error) BadRequest(format string, a ...interface{}) error

+ func (e *Error) Conflict(format string, a ...interface{}) error

+ func (e *Error) Forbidden(format string, a ...interface{}) error

+ func (e *Error) GatewayTimeout(format string, a ...interface{}) error

+ func (e *Error) InternalServerError(format string, a ...interface{}) error

+ func (e *Error) MethodNotAllowed(format string, a ...interface{}) error

+ func (e *Error) NotFound(format string, a ...interface{}) error

+ func (e *Error) NotImplemented(format string, a ...interface{}) error

+ func (e *Error) ServiceUnavailable(format string, a ...interface{}) error

+ func (e *Error) Timeout(format string, a ...interface{}) error

+ func (e *Error) Unauthorized(format string, a ...interface{}) error

+ type Handler interface

+ Endpoints func() []*register.Endpoint

+ Handler func() interface{}

+ Name func() string

+ Options func() HandlerOptions

+ type HandlerFunc func(ctx context.Context, req Request, rsp interface{}) error

+ type HandlerOption func(*HandlerOptions)

+ func EndpointMetadata(name string, md metadata.Metadata) HandlerOption

+ type HandlerOptions struct

+ Context context.Context

+ Metadata map[string]metadata.Metadata

+ func NewHandlerOptions(opts ...HandlerOption) HandlerOptions

+ type HandlerWrapper func(HandlerFunc) HandlerFunc

+ type Message interface

+ Body func() []byte

+ Codec func() codec.Codec

+ ContentType func() string

+ Header func() metadata.Metadata

+ Payload func() interface{}

+ Topic func() string

+ type Option func(*Options)

+ func Address(a string) Option

+ func Advertise(a string) Option

+ func Auth(a auth.Auth) Option

+ func Broker(b broker.Broker) Option

+ func Codec(contentType string, c codec.Codec) Option

+ func Context(ctx context.Context) Option

+ func ID(id string) Option

+ func Listener(l net.Listener) Option

+ func Logger(l logger.Logger) Option

+ func MaxConn(n int) Option

+ func Metadata(md metadata.Metadata) Option

+ func Meter(m meter.Meter) Option

+ func Name(n string) Option

+ func Namespace(n string) Option

+ func Register(r register.Register) Option

+ func RegisterCheck(fn func(context.Context) error) Option

+ func RegisterInterval(t time.Duration) Option

+ func RegisterTTL(t time.Duration) Option

+ func SetOption(k, v interface{}) Option

+ func TLSConfig(t *tls.Config) Option

+ func Tracer(t tracer.Tracer) Option

+ func Transport(t transport.Transport) Option

+ func Version(v string) Option

+ func Wait(wg *sync.WaitGroup) Option

+ func WrapBatchSubscriber(w BatchSubscriberWrapper) Option

+ func WrapHandler(w HandlerWrapper) Option

+ func WrapSubscriber(w SubscriberWrapper) Option

+ type Options struct

+ Address string

+ Advertise string

+ Auth auth.Auth

+ BatchSubWrappers []BatchSubscriberWrapper

+ Broker broker.Broker

+ Codecs map[string]codec.Codec

+ Context context.Context

+ DeregisterAttempts int

+ HdlrWrappers []HandlerWrapper

+ ID string

+ Listener net.Listener

+ Logger logger.Logger

+ MaxConn int

+ Metadata metadata.Metadata

+ Meter meter.Meter

+ Name string

+ Namespace string

+ Register register.Register

+ RegisterAttempts int

+ RegisterCheck func(context.Context) error

+ RegisterInterval time.Duration

+ RegisterTTL time.Duration

+ SubWrappers []SubscriberWrapper

+ TLSConfig *tls.Config

+ Tracer tracer.Tracer

+ Transport transport.Transport

+ Version string

+ Wait *sync.WaitGroup

+ func NewOptions(opts ...Option) Options

+ type Request interface

+ Body func() interface{}

+ Codec func() codec.Codec

+ ContentType func() string

+ Endpoint func() string

+ Header func() metadata.Metadata

+ Method func() string

+ Read func() ([]byte, error)

+ Service func() string

+ Stream func() bool

+ type Response interface

+ Codec func() codec.Codec

+ Write func([]byte) error

+ WriteHeader func(md metadata.Metadata)

+ type Server interface

+ Handle func(h Handler) error

+ Init func(...Option) error

+ Name func() string

+ NewHandler func(h interface{}, opts ...HandlerOption) Handler

+ NewSubscriber func(topic string, h interface{}, opts ...SubscriberOption) Subscriber

+ Options func() Options

+ Start func() error

+ Stop func() error

+ String func() string

+ Subscribe func(s Subscriber) error

+ var DefaultServer Server = NewServer()

+ func FromContext(ctx context.Context) (Server, bool)

+ func NewServer(opts ...Option) Server

+ type Stream interface

+ Close func() error

+ Context func() context.Context

+ Error func() error

+ Recv func(msg interface{}) error

+ Request func() Request

+ Send func(msg interface{}) error

+ type StreamWrapper func(Stream) Stream

+ type Subscriber interface

+ Endpoints func() []*register.Endpoint

+ Options func() SubscriberOptions

+ Subscriber func() interface{}

+ Topic func() string

+ type SubscriberFunc func(ctx context.Context, msg Message) error

+ type SubscriberOption func(*SubscriberOptions)

+ func DisableAutoAck() SubscriberOption

+ func SetSubscriberOption(k, v interface{}) SubscriberOption

+ func SubscriberAck(b bool) SubscriberOption

+ func SubscriberBatch(b bool) SubscriberOption

+ func SubscriberBatchSize(n int) SubscriberOption

+ func SubscriberBatchWait(td time.Duration) SubscriberOption

+ func SubscriberBodyOnly(b bool) SubscriberOption

+ func SubscriberContext(ctx context.Context) SubscriberOption

+ func SubscriberGroup(n string) SubscriberOption

+ func SubscriberQueue(n string) SubscriberOption

+ type SubscriberOptions struct

+ AutoAck bool

+ Batch bool

+ BatchSize int

+ BatchWait time.Duration

+ BodyOnly bool

+ Context context.Context

+ Queue string

+ func NewSubscriberOptions(opts ...SubscriberOption) SubscriberOptions

+ type SubscriberWrapper func(SubscriberFunc) SubscriberFunc