server

Documentation

Index

• Constants
• func ConfigAdd(path string)
• type Options
  • func NewOptions() (*Options, error)
  • func NewOptionsWithPath(path string) (opts *Options, err error)
• type Server
  • func NewServer(ctx context.Context) (*Server, error)
  • func NewServerWithConfigPath(ctx context.Context, path string) (*Server, error)
  • func NewServerWithOptions(ctx context.Context, opt *Options) (*Server, error)
  • func (s *Server) Mux() *drpcmux.Mux
  • func (s *Server) Serve(ctx context.Context)
  • func (s *Server) Server() *drpcserver.Server
  • func (s *Server) Shutdown(ctx context.Context)

Constants

const (
	PluginsRoot = root + ".plugins"
)

Functions

func ConfigAdd

func ConfigAdd(path string)

Types

type Options

type Options struct {
	Port int
}

Options drpc server options.

func NewOptions

func NewOptions() (*Options, error)

NewOptions returns options from config file or environment vars.

func NewOptionsWithPath

func NewOptionsWithPath(path string) (opts *Options, err error)

NewOptionsWithPath unmarshals a given key path into options and returns it.

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server represents a drpc server.

func NewServer

func NewServer(ctx context.Context) (*Server, error)

NewServer returns a new drpc server with default options.

func NewServerWithConfigPath

func NewServerWithConfigPath(ctx context.Context, path string) (*Server, error)

NewServerWithConfigPath returns a new drpc server with options from config path.

func NewServerWithOptions

func NewServerWithOptions(ctx context.Context, opt *Options) (*Server, error)

NewServerWithOptions returns a new drpc server with options.

func (*Server) Mux

func (s *Server) Mux() *drpcmux.Mux

Mux returns the wrapped drpc mux instance.

func (*Server) Serve

func (s *Server) Serve(ctx context.Context)

Serve starts drpc server.

func (*Server) Server

func (s *Server) Server() *drpcserver.Server

Server returns the wrapped drpc server instance.

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context)

Shutdown stops drpc server gracefully.