server

Documentation

Index

• type Grpc
  • func NewGrpc(name string, cfg GrpcConfig) *Grpc
  • func (t *Grpc) Init(app interfaces.IEngine) error
  • func (t *Grpc) RegisterService(desc *grpc.ServiceDesc, impl any)
  • func (t *Grpc) Start() error
  • func (t *Grpc) Stop() error
  • func (t *Grpc) String() string
• type GrpcConfig
• type Http
  • func NewHttp(name string, cfg HttpConfig) *Http
  • func (t *Http) Init(app interfaces.IEngine) error
  • func (t *Http) PushRoute(method string, path string, handler interfaces.RouteFunc, middlewares []string)
  • func (t *Http) ServeHTTP(w http.ResponseWriter, req *http.Request)
  • func (t *Http) Start() error
  • func (t *Http) Stop() error
  • func (t *Http) String() string
• type HttpConfig
• type Kafka
  • func NewKafka(name string, cfg KafkaConfig) *Kafka
  • func (t *Kafka) Handle(msg *kafka.Message)
  • func (t *Kafka) Init(app interfaces.IEngine) error
  • func (t *Kafka) PushRoute(method string, path string, handler interfaces.RouteFunc, middlewares []string)
  • func (t *Kafka) Start() error
  • func (t *Kafka) Stop() error
  • func (t *Kafka) String() string
• type KafkaConfig
• type Mock
  • func (t *Mock) Init(_ interfaces.IEngine) error
  • func (t *Mock) Start() error
  • func (t *Mock) Stop() error
  • func (t *Mock) String() string
• type Router
  • func NewRouter(app interfaces.IEngine) *Router
  • func (t *Router) Find(method string, path string) (interfaces.RouteFunc, map[string]string)
  • func (t *Router) PushRoute(method string, path string, handler interfaces.RouteFunc, middlewares []string)

Types

type Grpc

type Grpc struct {
	Name   string
	Config GrpcConfig
	// contains filtered or unexported fields
}

func NewGrpc

func NewGrpc(name string, cfg GrpcConfig) *Grpc

func (*Grpc) Init

func (t *Grpc) Init(app interfaces.IEngine) error

func (*Grpc) RegisterService

func (t *Grpc) RegisterService(desc *grpc.ServiceDesc, impl any)

func (*Grpc) Start

func (t *Grpc) Start() error

func (*Grpc) Stop

func (t *Grpc) Stop() error

func (*Grpc) String

func (t *Grpc) String() string

type GrpcConfig

type GrpcConfig struct {
	Port string `yaml:"port"`
}

type Http

type Http struct {
	Name   string
	Config HttpConfig
	// contains filtered or unexported fields
}

func NewHttp

func NewHttp(name string, cfg HttpConfig) *Http

func (*Http) Init

func (t *Http) Init(app interfaces.IEngine) error

func (*Http) PushRoute

func (t *Http) PushRoute(method string, path string, handler interfaces.RouteFunc, middlewares []string)

func (*Http) ServeHTTP

func (t *Http) ServeHTTP(w http.ResponseWriter, req *http.Request)

func (*Http) Start

func (t *Http) Start() error

func (*Http) Stop

func (t *Http) Stop() error

func (*Http) String

func (t *Http) String() string

type HttpConfig

type HttpConfig struct {
	Port string `yaml:"port"`

	CookieDomain   string `yaml:"cookie_domain"`
	CookieSameSite string `yaml:"cookie_same_site"`
	CookieHttpOnly bool   `yaml:"cookie_http_only"`
	CookieSecure   bool   `yaml:"cookie_secure"`

	BaseMiddleware []string `yaml:"base_middleware"`
}

type Kafka

type Kafka struct {
	Name string

	Config KafkaConfig
	// contains filtered or unexported fields
}

func NewKafka

func NewKafka(name string, cfg KafkaConfig) *Kafka

func (*Kafka) Handle

func (t *Kafka) Handle(msg *kafka.Message)

func (*Kafka) Init

func (t *Kafka) Init(app interfaces.IEngine) error

func (*Kafka) PushRoute

func (t *Kafka) PushRoute(method string, path string, handler interfaces.RouteFunc, middlewares []string)

func (*Kafka) Start

func (t *Kafka) Start() error

func (*Kafka) Stop

func (t *Kafka) Stop() error

func (*Kafka) String

func (t *Kafka) String() string

type KafkaConfig

type KafkaConfig struct {
	Hosts             string   `yaml:"hosts"`
	GroupId           string   `yaml:"group_id"`
	User              string   `yaml:"user"`
	Password          string   `yaml:"password"`
	Topics            []string `yaml:"topics"`
	LimitMessageCount int64    `yaml:"limit_message_count"`
	BaseMiddleware    []string `yaml:"base_middleware"`
}

type Mock

type Mock struct {
	Name string
}

func (*Mock) Init

func (t *Mock) Init(_ interfaces.IEngine) error

func (*Mock) Start

func (t *Mock) Start() error

func (*Mock) Stop

func (t *Mock) Stop() error

func (*Mock) String

func (t *Mock) String() string

type Router

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

func NewRouter

func NewRouter(app interfaces.IEngine) *Router

func (*Router) Find

func (t *Router) Find(method string, path string) (interfaces.RouteFunc, map[string]string)

func (*Router) PushRoute

func (t *Router) PushRoute(method string, path string, handler interfaces.RouteFunc, middlewares []string)