Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v0

v0.17.0

Jan 3, 2019

v0.14.1

Nov 22, 2018

v0.13.0

Nov 15, 2018

v0.11.0

Aug 18, 2018

Changes in this version

+ type Message interface

+ ContentType func() string

+ Payload func() interface{}

+ Topic func() string

+ type Stream interface

+ Close func() error

+ Context func() context.Context

+ Error func() error

+ Recv func(interface{}) error

+ Request func() Request

+ Send func(interface{}) error

+ type StreamWrapper func(Stream) Stream

v0.7.0

Apr 8, 2018

v0.4.0

Feb 19, 2018

v0.3.0

Jan 2, 2018

v0.1.4

Aug 25, 2017

Changes in this version

+ var DefaultAddress = ":0"

+ var DefaultId = uuid.NewUUID().String()

+ var DefaultName = "go-server"

+ var DefaultServer Server = newRpcServer()

+ var DefaultVersion = "1.0.0"

+ func Deregister() error

+ func Handle(h Handler) error

+ func Init(opt ...Option)

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

+ func Register() error

+ func Run() error

+ func Start() error

+ func Stop() error

+ func String() string

+ func Subscribe(s Subscriber) error

+ type Debug struct

+ type Handler interface

+ Endpoints func() []*registry.Endpoint

+ Handler func() interface{}

+ Name func() string

+ Options func() HandlerOptions

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

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

+ type HandlerOption func(*HandlerOptions)

+ func EndpointMetadata(name string, md map[string]string) HandlerOption

+ func InternalHandler(b bool) HandlerOption

+ type HandlerOptions struct

+ Internal bool

+ Metadata map[string]map[string]string

+ type HandlerWrapper func(HandlerFunc) HandlerFunc

+ type Option func(*Options)

+ func Address(a string) Option

+ func Advertise(a string) Option

+ func Broker(b broker.Broker) Option

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

+ func DebugHandler(d debug.DebugHandler) Option

+ func Id(id string) Option

+ func Metadata(md map[string]string) Option

+ func Name(n string) Option

+ func RegisterTTL(t time.Duration) Option

+ func Registry(r registry.Registry) Option

+ func Transport(t transport.Transport) Option

+ func Version(v string) Option

+ func Wait(b bool) Option

+ func WrapHandler(w HandlerWrapper) Option

+ func WrapSubscriber(w SubscriberWrapper) Option

+ type Options struct

+ Address string

+ Advertise string

+ Broker broker.Broker

+ Codecs map[string]codec.NewCodec

+ Context context.Context

+ DebugHandler debug.DebugHandler

+ HdlrWrappers []HandlerWrapper

+ Id string

+ Metadata map[string]string

+ Name string

+ RegisterTTL time.Duration

+ Registry registry.Registry

+ SubWrappers []SubscriberWrapper

+ Transport transport.Transport

+ Version string

+ func DefaultOptions() Options

+ type Publication interface

+ ContentType func() string

+ Message func() interface{}

+ Topic func() string

+ type Request interface

+ ContentType func() string

+ Method func() string

+ Request func() interface{}

+ Service func() string

+ Stream func() bool

+ type Server interface

+ Deregister func() error

+ Handle func(Handler) error

+ Init func(...Option) error

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

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

+ Options func() Options

+ Register func() error

+ Start func() error

+ Stop func() error

+ String func() string

+ Subscribe func(Subscriber) error

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

+ func NewServer(opt ...Option) Server

+ type Streamer interface

+ Close func() error

+ Context func() context.Context

+ Error func() error

+ Recv func(interface{}) error

+ Request func() Request

+ Send func(interface{}) error

+ type StreamerWrapper func(Streamer) Streamer

+ type Subscriber interface

+ Endpoints func() []*registry.Endpoint

+ Options func() SubscriberOptions

+ Subscriber func() interface{}

+ Topic func() string

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

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

+ type SubscriberOption func(*SubscriberOptions)

+ func InternalSubscriber(b bool) SubscriberOption

+ func SubscriberQueue(n string) SubscriberOption

+ type SubscriberOptions struct

+ Internal bool

+ Queue string

+ type SubscriberWrapper func(SubscriberFunc) SubscriberFunc