interfaces

Documentation

Index

• Variables
• func CreateDiscoveryRequest(id string, driver string) *global.DiscoveryRequest
• func CreatePushRequest(id string, r *http.Request) *global.PushRequest
• func CreatePushResponse(id string, statusCode int, endOfStreams bool, h http.Header, body []byte) *global.PushResponse
• type CertStorage
• type EventTypeProcess
• type Interceptor
• type Listener
• type Method
• type MethodMultipleHandler
• type MultipleHandlerOption
• type OnPushMessage
• type OnPushMessageResponse
• type Options
• type Port
• type RequestContext
  • func (c *RequestContext) GetQuery() (val func() url.Values)
  • func (c *RequestContext) GetRequestID() (val string)
  • func (c *RequestContext) SetQuery(val func() url.Values)
  • func (c *RequestContext) SetRequestID(val string)
• type RequestContextType
• type TLSCerts
• type TcpConnectionInformation
• type TcpHandler
• type TcpHandlerOnDone
• type UseAuthCallback
• type WebSocketHandler
• type WebSocketHandlerOnMsg

Variables

var DefaultServices = map[string]bool{
	"debug.Testing/Input":  true,
	"debug.Testing/Stream": true,
	"debug.Info/Request":   true,
	"grpc.reflection.v1alpha.ServerReflection/ServerReflectionInfo": true,
}

Functions

func CreateDiscoveryRequest

func CreateDiscoveryRequest(id string, driver string) *global.DiscoveryRequest

func CreatePushRequest

func CreatePushRequest(id string, r *http.Request) *global.PushRequest

func CreatePushResponse

func CreatePushResponse(id string, statusCode int,
	endOfStreams bool, h http.Header, body []byte) *global.PushResponse

Types

type CertStorage

type CertStorage interface {
	Init() error
	GetCrt() (s [][]byte)
	OnChange(func())
}

type EventTypeProcess

type EventTypeProcess string

const (
	EventTypeProcessSplitter               EventTypeProcess = "http.splitter"
	EventTypeProcessHttpHandler            EventTypeProcess = "http.handler"
	EventTypeProcessHttpController         EventTypeProcess = "http.controller"
	EventTypeProcessGRPCWebController      EventTypeProcess = "grpc.web.controller"
	EventTypeProcessGRPCController         EventTypeProcess = "grpc.controller"
	EventTypeProcessHttpMiddlewareCompress EventTypeProcess = "http.middleware.compress"
)

type Interceptor

type Interceptor interface {
	Handler(http.Handler) http.Handler
	UnaryServerInterceptor() grpc.UnaryServerInterceptor
	StreamServerInterceptor() grpc.StreamServerInterceptor
}

type Listener

type Listener interface {
	Init(opt Options, interceptor ...Interceptor)
	Run() (err error)
	RunRouter() (err error)

	RegisterMultipleHandler(MethodMultipleHandler)
	RegisterHttpHandler(path, method string, handler http.Handler)
	PushRouterListener(*listener.RouterListener, http.HandlerFunc)
	PushRouterHProxyListener(l *listener.RouterListener, h http.HandlerFunc)
	PushRouterTcpListener(*listener.RouterListener, TcpHandler)
	RemoveRouterListener(name string) error
	RemoveRouterTcpListener(name string) error
	SetTracer(tracing.Tracing)

	UseWebSocket(pa string, onConnected WebSocketHandler, onMsg WebSocketHandlerOnMsg,
		onDisconnected WebSocketHandler) error

	GetInterceptor() (interceptor []Interceptor)
	GetServices() []string
	GetAllServices() (res []*listener.ServicesItems)
	GetOptions() Options
	GetTracer() tracing.Tracing
	NewMonitor() (mm interface{})
	SetMonitor(interface{})
	GetMonitor() (mm interface{})
	GetMonitorResponse() *listener.MonitorResponse
	GetLimiter() *limiter.Limiter
	GetGrpcServer() *grpc.Server
	GetTLSCerts() TLSCerts
}

type Method

type Method string

const (
	MethodGET    Method = "GET"
	MethodPOST   Method = "POST"
	MethodPUT    Method = "PUT"
	MethodDELETE Method = "DELETE"
)

type MethodMultipleHandler

type MethodMultipleHandler interface{}

type MultipleHandlerOption

type MultipleHandlerOption interface {
	GetServiceDesc() []*grpc.ServiceDesc
	AllowMethod(string) []Method
}

MultipleHandlerOption -

type OnPushMessage

type OnPushMessage func(data *global.PushRequest, onMsg OnPushMessageResponse)

type OnPushMessageResponse

type OnPushMessageResponse func(*global.PushResponse)

type Options

type Options struct {
	ServiceName         string
	Listen              string
	Port                Port
	Logger              logger.Logger
	Pem                 string
	Vault               *listener.Vault
	AutoReloadPemDir    bool
	DisableSecure       bool
	IsRouter            bool
	EnableEncryption    bool
	Database            database.Database
	Discover            *listener.Discovery
	MaxRequest          int64
	Driver              string
	UseAuthCallback     UseAuthCallback
	ServiceInfo         *listener.ServicesInfo
	DisableMonitor      bool
	DefaultAllowHeaders []string
}

type Port

type Port struct {
	Insecure int
	Secure   int
}

type RequestContext

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

func (*RequestContext) GetQuery

func (c *RequestContext) GetQuery() (val func() url.Values)

func (*RequestContext) GetRequestID

func (c *RequestContext) GetRequestID() (val string)

func (*RequestContext) SetQuery

func (c *RequestContext) SetQuery(val func() url.Values)

func (*RequestContext) SetRequestID

func (c *RequestContext) SetRequestID(val string)

type RequestContextType

type RequestContextType string

const RequestContexWebSocket RequestContextType = "RequestContexWebSocket"

type TLSCerts

type TLSCerts interface {
	Init()
	NewConfig(name string, dir string, autoReload bool, disableHttp2 bool, vault *listener.Vault) *tls.Config
}

type TcpConnectionInformation

type TcpConnectionInformation struct {
	Secure      bool
	ClientHello *tls.ClientHelloInfo
}

type TcpHandler

type TcpHandler func(conn net.Conn, info *TcpConnectionInformation, onDone TcpHandlerOnDone)

type TcpHandlerOnDone

type TcpHandlerOnDone func()

type UseAuthCallback

type UseAuthCallback func(r *http.Request) bool

type WebSocketHandler

type WebSocketHandler func(ctx context.Context, c *websocket.Conn) error

type WebSocketHandlerOnMsg

type WebSocketHandlerOnMsg func(ctx context.Context, data []byte, c *websocket.Conn) error