server

Documentation

Index

• Constants
• func Error(err error) error
• func ToStruct(v map[string]interface{}) *st.Struct
• func ToValue(v interface{}) *st.Value
• type Options
  • func NewOptions() (*Options, error)
  • func NewOptionsWithPath(path string) (opts *Options, err error)
• type Plugin
• type Server
  • func NewServer(ctx context.Context, plugins ...Plugin) *Server
  • func NewServerWithOptions(ctx context.Context, opt *Options, plugins ...Plugin) *Server
  • func (s *Server) Serve(ctx context.Context)
  • func (s *Server) Server() *grpc.Server
  • func (s *Server) ServiceRegistrar() grpc.ServiceRegistrar

Constants

const (
	PluginsRoot = root + ".plugins"
)

Functions

func Error

func Error(err error) error

func ToStruct

func ToStruct(v map[string]interface{}) *st.Struct

ToStruct converts a map[string]interface{} to a ptypes.Struct

func ToValue

func ToValue(v interface{}) *st.Value

ToValue converts an interface{} to a ptypes.Value

Types

type Options

type Options struct {
	Port                  int
	MaxConcurrentStreams  int64
	InitialWindowSize     int32
	InitialConnWindowSize int32
	TLS                   struct {
		Enabled  bool
		CertFile string
		KeyFile  string
		CAFile   string `config:"caFile"`
	} `config:"tls"`
}

func NewOptions

func NewOptions() (*Options, error)

func NewOptionsWithPath

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

type Plugin

type Plugin func(ctx context.Context) []grpc.ServerOption

type Server

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

func NewServer

func NewServer(ctx context.Context, plugins ...Plugin) *Server

func NewServerWithOptions

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

func (*Server) Serve

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

func (*Server) Server

func (s *Server) Server() *grpc.Server

func (*Server) ServiceRegistrar

func (s *Server) ServiceRegistrar() grpc.ServiceRegistrar