api

Documentation

Index

• type Config
  • func NewDefaultConfig() Config
• type GRPCUIConfig
  • func NewDefaultGRPCUIConfig() GRPCUIConfig
• type GRPCUIHandler
  • func NewGRPCUIHandler(log *logging.Logger, dialer grpcDialer, config GRPCUIConfig) *GRPCUIHandler
  • func (g *GRPCUIHandler) Name() string
  • func (g *GRPCUIHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (g *GRPCUIHandler) Start() error
• type Gateway
  • func NewGateway(log *logging.Logger, config GatewayConfig) *Gateway
  • func (s *Gateway) Register(handler GatewayHandler, endpoint string)
  • func (s *Gateway) Serve(lis net.Listener) error
• type GatewayConfig
  • func NewDefaultGatewayConfig() GatewayConfig
• type GatewayHandler
• type NotStarted
  • func NewNotStartedHandler(name string) *NotStarted
  • func (n *NotStarted) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type Portal
  • func NewPortal(config Config, log *logging.Logger) *Portal
  • func (p *Portal) GRPCListener() net.Listener
  • func (p *Portal) GatewayListener() net.Listener
  • func (p *Portal) Serve() error
• type RESTConfig
  • func NewDefaultRESTConfig() RESTConfig
• type RESTHandler
  • func NewRESTHandler(log *logging.Logger, dialer grpcDialer, config RESTConfig) *RESTHandler
  • func (r *RESTHandler) Name() string
  • func (r *RESTHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)
  • func (r *RESTHandler) Start() error

Types

type Config

type Config struct {
	GRPC          grpc.Config   `group:"grpc api" namespace:"grpc"`
	GRPCUI        GRPCUIConfig  `group:"grpc web ui" namespace:"grpcui"`
	REST          RESTConfig    `group:"rest api" namespace:"rest"`
	Gateway       GatewayConfig `group:"gateway" namespace:"grpcui"`
	ListenAddress string        `long:"listen-address" description:"the IP address that our sever will listen on"`
	ListenPort    uint16        `long:"listen-port" description:"the port that our sever will listen on"`
}

func NewDefaultConfig

func NewDefaultConfig() Config

type GRPCUIConfig

type GRPCUIConfig struct {
	Enabled        encoding.Bool     `long:"enabled"`
	Endpoint       string            `long:"endpoint"`
	Level          encoding.LogLevel `long:"log-level" choice:"debug" choice:"info" choice:"warning"`
	MaxPayloadSize encoding.ByteSize `long:"max-payload-size" description:"Maximum size of GRPC messages the UI will accept from the GRPC server (e.g. 4mb)"`
}

func NewDefaultGRPCUIConfig

func NewDefaultGRPCUIConfig() GRPCUIConfig

type GRPCUIHandler

type GRPCUIHandler struct {
	GRPCUIConfig
	// contains filtered or unexported fields
}

func NewGRPCUIHandler

func NewGRPCUIHandler(log *logging.Logger, dialer grpcDialer, config GRPCUIConfig) *GRPCUIHandler

func (*GRPCUIHandler) Name

func (g *GRPCUIHandler) Name() string

func (*GRPCUIHandler) ServeHTTP

func (g *GRPCUIHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*GRPCUIHandler) Start

func (g *GRPCUIHandler) Start() error

type Gateway

type Gateway struct {
	GatewayConfig
	// contains filtered or unexported fields
}

func NewGateway

func NewGateway(log *logging.Logger, config GatewayConfig) *Gateway

func (*Gateway) Register

func (s *Gateway) Register(handler GatewayHandler, endpoint string)

func (*Gateway) Serve

func (s *Gateway) Serve(lis net.Listener) error

type GatewayConfig

type GatewayConfig struct {
	CORS libhttp.CORSConfig `long:"cors" description:"CORS allowed origins"`
}

func NewDefaultGatewayConfig

func NewDefaultGatewayConfig() GatewayConfig

type GatewayHandler

type GatewayHandler interface {
	http.Handler
	Name() string
}

type NotStarted

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

func NewNotStartedHandler

func NewNotStartedHandler(name string) *NotStarted

func (*NotStarted) ServeHTTP

func (n *NotStarted) ServeHTTP(w http.ResponseWriter, req *http.Request)

type Portal

type Portal struct {
	Config
	// contains filtered or unexported fields
}

func NewPortal

func NewPortal(config Config, log *logging.Logger) *Portal

func (*Portal) GRPCListener

func (p *Portal) GRPCListener() net.Listener

func (*Portal) GatewayListener

func (p *Portal) GatewayListener() net.Listener

func (*Portal) Serve

func (p *Portal) Serve() error

type RESTConfig

type RESTConfig struct {
	Level    encoding.LogLevel `long:"log-level" choice:"debug" choice:"info" choice:"warning"`
	Enabled  encoding.Bool     `long:"enabled"`
	Endpoint string            `long:"endpoint"`
}

func NewDefaultRESTConfig

func NewDefaultRESTConfig() RESTConfig

type RESTHandler

type RESTHandler struct {
	RESTConfig
	// contains filtered or unexported fields
}

Handler implement a rest server acting as a proxy to the grpc api.

func NewRESTHandler

func NewRESTHandler(log *logging.Logger, dialer grpcDialer, config RESTConfig) *RESTHandler

func (*RESTHandler) Name

func (r *RESTHandler) Name() string

func (*RESTHandler) ServeHTTP

func (r *RESTHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

func (*RESTHandler) Start

func (r *RESTHandler) Start() error