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 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 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 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)
	// handle grpc, grpc-web and http
	RegisterMultipleHandler(MethodMultipleHandler)
	RegisterHttpHandler(path, method string, handler http.Handler)
	PushRouterListener(*listener.RouterListener, http.HandlerFunc)
	SetTracer(tracing.Tracing)

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

	//Get from main modules
	GetInterceptor() (interceptor []Interceptor)
	GetServices() []string
	GetAllServices() (res []*listener.ServicesItems)
	GetOptions() Options
	GetTracer() tracing.Tracing
	GetMonitor() *listener.MonitorResponse
}

listener modules interface, using for dynamic modules

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
	DisableSecure    bool
	IsRouter         bool
	EnableEncryption bool
	Database         database.Database
	Discover         *listener.Discovery
	MaxRequest       int64
	Driver           string
	UseAuthCallback  UseAuthCallback
	ServiceInfo      *listener.ServicesInfo
}

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 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