interfaces

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

type DefaultError struct {
	Error   bool        `json:"error"`
	Message interface{} `json:"message"`
}

type Encryption interface {
	Encrypt(data []byte) (res []byte, err error)
	Decrypt(data []byte) (res []byte, err error)
}

type EndToEndOption struct {
	Storage         KeyStorage
	SessionTimeout  time.Duration
	PrivateKey      string
	PublicKey       string
	MustBeEncrypted bool
	ByPassRequest   map[string]bool
}

type EventTypeProcess string

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

type KeyStorage interface {
	Set(id string, clientPublicKey []byte, serverPair encrypt.BoxKeyPair, alive time.Duration) error
	Get(id string) (response *proto.DefaultStorageItem, err error)
}

type Limiter struct {
	Enable      bool    `yaml:"enable" default:"false"`
	Max         float64 `yaml:"max" default:"100"`
	PerIp       bool    `yaml:"perIp" default:"false"`
	EveryMinute bool    `yaml:"everyMinute" default:"false"`
}

type Listener interface {
	Init(opt Options, interceptor ...Interceptor) Listener
	//InitProcess - Without starting listener
	InitProcess(opt Options, interceptor ...Interceptor)
	Run() (err error)
	Close()
	RegisterMultipleHandler(MethodMultipleHandler)
	RegisterHttpHandler(path, method string, handler http.Handler)
	RegisterHttpPrefixHandler(path, method string, handler http.Handler)
	SetTracer(tracing.Tracing)
	UseWebSocket(pa string, onConnected WebSocketHandler, onMsg WebSocketHandlerOnMsg,
		onDisconnected WebSocketHandler) error
	GetInterceptor() (interceptor []Interceptor)
	GetServices() []string
	GetAllServices() (res []*proto.ServicesItems)
	GetOptions() Options
	GetTracer() tracing.Tracing
	NewMonitor() (mm interface{})
	SetMonitor(interface{})
	GetMonitor() (mm interface{})
	GetMonitorResponse() *proto.MonitorResponse
	GetLimiter() *limiter.Limiter
	GetGrpcServer() *grpc.Server
	GetTLSCerts() TLSCerts
	GlobalContext() context.Context
	UseGrpcEncryption(codec encoding.Codec)
	UseEndToEndEncryption(opts EndToEndOption) Listener
}

type Method string

type MethodMultipleHandler interface{}

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

type Option interface {
	Apply(Listener)
}

type Options struct {
	ServiceName      string
	Listen           string
	Port             Port
	Logger           logger.Logger
	Pem              string
	Vault            *proto.Vault
	AutoReloadPemDir bool
	DisableSecure    bool
	EnableEncryption bool
	Driver           string
	UseAuthCallback  UseAuthCallback
	ServiceInfo      *proto.ServicesInfo
	DisableMonitor   bool
	Limiter          Limiter
	TraceLog         tracingInterface.DefaultLogSpanSave
}

type Port struct {
	Insecure int
	Secure   int
}

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

type RequestContextType string

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

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

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

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

type TcpHandlerOnDone func()

type UseAuthCallback func(r *http.Request) bool

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

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