server

Documentation

Index

• type Http
  • func NewHttp(name string, cfg HttpConfig) *Http
  • func (t *Http) Init(app interfaces.IService) 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.IService) 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 NewMock(name string) *Mock
  • func (t *Mock) Init(app interfaces.IService) error
  • func (t *Mock) PushRoute(method string, path string, handler interfaces.RouteFunc, middlewares []string)
  • func (t *Mock) Start() error
  • func (t *Mock) Stop() error
  • func (t *Mock) String() string
• type Router
  • func NewRouter(app interfaces.IService) *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 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.IService) 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.IService) 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
	RouteRegister func(router *Router)
	// contains filtered or unexported fields
}

func NewMock

func NewMock(name string) *Mock

func (*Mock) Init

func (t *Mock) Init(app interfaces.IService) error

func (*Mock) PushRoute

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

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.IService) *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)