server

Documentation

Index

• Variables
• func GetContext(r *http.Request) *serverContext
• func Init() error
• func Register(r Receiver) error
• func Run() error
• func Start() error
• func Stop() error
• type Context
  • func NewContext(ctx context.Context) (Context, bool)
• type Headers
• type Receiver
  • func NewNamedReceiver(path string, handler interface{}) Receiver
  • func NewReceiver(handler interface{}) Receiver
• type Request
• type RpcReceiver
  • func NewNamedRpcReceiver(name string, handler interface{}) *RpcReceiver
  • func NewRpcReceiver(handler interface{}) *RpcReceiver
  • func (r *RpcReceiver) Handler() interface{}
  • func (r *RpcReceiver) Name() string
• type RpcServer
  • func NewRpcServer(address string) *RpcServer
  • func (s *RpcServer) Address() string
  • func (s *RpcServer) Init() error
  • func (s *RpcServer) NewNamedReceiver(name string, handler interface{}) Receiver
  • func (s *RpcServer) NewReceiver(handler interface{}) Receiver
  • func (s *RpcServer) Register(r Receiver) error
  • func (s *RpcServer) ServeHTTP(w http.ResponseWriter, req *http.Request)
  • func (s *RpcServer) Start() error
  • func (s *RpcServer) Stop() error
• type Server

Variables

var (
	HealthPath = "/_status/health"
	RpcPath    = "/_rpc"
)

var (
	Address       string
	Name          string
	Id            string
	DefaultServer Server
)

Functions

func GetContext

func GetContext(r *http.Request) *serverContext

func Init

func Init() error

func Register

func Register(r Receiver) error

func Run

func Run() error

func Start

func Start() error

func Stop

func Stop() error

Types

type Context

type Context interface {
	Request() Request                                           // the request made to the server
	Headers() Headers                                           // the response headers
	NewRequest(string, string, interface{}) client.Request      // a new scoped client request
	NewProtoRequest(string, string, interface{}) client.Request // a new scoped client request
	NewJsonRequest(string, string, interface{}) client.Request  // a new scoped client request
}

A server context interface

func NewContext

func NewContext(ctx context.Context) (Context, bool)

return server.Context

type Headers

type Headers interface {
	Add(string, string)
	Del(string)
	Get(string) string
	Set(string, string)
}

type Receiver

type Receiver interface {
	Name() string
	Handler() interface{}
}

func NewNamedReceiver

func NewNamedReceiver(path string, handler interface{}) Receiver

func NewReceiver

func NewReceiver(handler interface{}) Receiver

type Request

type Request interface {
	Headers() Headers
	Session(string) string
}

type RpcReceiver

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

func NewNamedRpcReceiver

func NewNamedRpcReceiver(name string, handler interface{}) *RpcReceiver

func NewRpcReceiver

func NewRpcReceiver(handler interface{}) *RpcReceiver

func (*RpcReceiver) Handler

func (r *RpcReceiver) Handler() interface{}

func (*RpcReceiver) Name

func (r *RpcReceiver) Name() string

type RpcServer

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

func NewRpcServer

func NewRpcServer(address string) *RpcServer

func (*RpcServer) Address

func (s *RpcServer) Address() string

func (*RpcServer) Init

func (s *RpcServer) Init() error

func (*RpcServer) NewNamedReceiver

func (s *RpcServer) NewNamedReceiver(name string, handler interface{}) Receiver

func (*RpcServer) NewReceiver

func (s *RpcServer) NewReceiver(handler interface{}) Receiver

func (*RpcServer) Register

func (s *RpcServer) Register(r Receiver) error

func (*RpcServer) ServeHTTP

func (s *RpcServer) ServeHTTP(w http.ResponseWriter, req *http.Request)

func (*RpcServer) Start

func (s *RpcServer) Start() error

func (*RpcServer) Stop

func (s *RpcServer) Stop() error

type Server

type Server interface {
	Address() string
	Init() error
	NewReceiver(interface{}) Receiver
	NewNamedReceiver(string, interface{}) Receiver
	Register(Receiver) error
	Start() error
	Stop() error
}