mqc

Documentation

Index

• Constants
• type Body
• type Config
  • func (c Config) String() string
• type Option
  • func Log(opts ...log.ServerOption) Option
  • func WithConfig(config config.Config) Option
  • func WithServiceName(serviceName string) Option
• type Request
  • func NewRequest(task *Task, m queue.IMQCMessage) (r *Request, err error)
  • func (m *Request) Body() []byte
  • func (m *Request) Context() sctx.Context
  • func (m *Request) GetHeader() map[string]string
  • func (m *Request) GetMethod() string
  • func (m *Request) GetName() string
  • func (m *Request) GetRemoteAddr() string
  • func (m *Request) GetService() string
  • func (m *Request) Params() map[string]string
  • func (m *Request) WithContext(ctx sctx.Context) alloter.IRequest
• type Response
  • func NewResponse(task *Task, msg queue.IMQCMessage) (r *Response, err error)
  • func (r *Response) Flush() error
  • func (r *Response) Header() xtypes.SMap
  • func (r *Response) Size() int
  • func (r *Response) Status() int
  • func (r *Response) Write(data []byte) (n int, err error)
  • func (r *Response) WriteHeader(code int)
  • func (r *Response) WriteString(s string) (n int, err error)
  • func (r *Response) Written() bool
• type Server
  • func New(name string, opts ...Option) *Server
  • func (e *Server) Attempt() bool
  • func (e *Server) Config(cfg config.Config)
  • func (e *Server) Endpoint() *url.URL
  • func (e *Server) Group(group string, middlewares ...middleware.Middleware) *server.RouterGroup
  • func (e *Server) Handle(queue string, obj interface{})
  • func (e *Server) Name() string
  • func (e *Server) Options(opts ...Option)
  • func (s *Server) ServiceName() string
  • func (e *Server) Start(ctx context.Context) error
  • func (e *Server) Stop(ctx context.Context) error
  • func (e *Server) Type() string
  • func (e *Server) Use(middlewares ...middleware.Middleware)
• type Setting
• type Task
  • func (t *Task) GetService() string

Constants

const Type string = "mqc"

Types

type Body

type Body interface {
	io.Reader
	Scan(obj interface{}) error
}

type Config

type Config struct {
	Addr   string        `json:"addr"`
	Status server.Status `json:"status"`
}

func (Config) String

func (c Config) String() string

type Option

type Option func(*options)

Option 参数设置类型

func Log

func Log(opts ...log.ServerOption) Option

Log 设置日志配置

func WithConfig

func WithConfig(config config.Config) Option

WithStartedHook 设置启动回调函数

func WithServiceName

func WithServiceName(serviceName string) Option

WithServiceName 设置服务名称

type Request

type Request struct {
	queue.IMQCMessage
	// contains filtered or unexported fields
}

Request 处理任务请求

func NewRequest

func NewRequest(task *Task, m queue.IMQCMessage) (r *Request, err error)

NewRequest 构建任务请求

func (*Request) Body

func (m *Request) Body() []byte

func (*Request) Context

func (m *Request) Context() sctx.Context

func (*Request) GetHeader

func (m *Request) GetHeader() map[string]string

func (*Request) GetMethod

func (m *Request) GetMethod() string

GetMethod 方法名

func (*Request) GetName

func (m *Request) GetName() string

GetName 获取任务名称

func (*Request) GetRemoteAddr

func (m *Request) GetRemoteAddr() string

func (*Request) GetService

func (m *Request) GetService() string

GetService 服务名

func (*Request) Params

func (m *Request) Params() map[string]string

func (*Request) WithContext

func (m *Request) WithContext(ctx sctx.Context) alloter.IRequest

type Response

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

Request 处理任务请求

func NewResponse

func NewResponse(task *Task, msg queue.IMQCMessage) (r *Response, err error)

NewRequest 构建任务请求

func (*Response) Flush

func (r *Response) Flush() error

func (*Response) Header

func (r *Response) Header() xtypes.SMap

func (*Response) Size

func (r *Response) Size() int

func (*Response) Status

func (r *Response) Status() int

func (*Response) Write

func (r *Response) Write(data []byte) (n int, err error)

func (*Response) WriteHeader

func (r *Response) WriteHeader(code int)

func (*Response) WriteString

func (r *Response) WriteString(s string) (n int, err error)

Writes the string into the response body.

func (*Response) Written

func (r *Response) Written() bool

Returns true if the response body was already written.

type Server

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

func New

func New(name string, opts ...Option) *Server

New 实例化

func (*Server) Attempt

func (e *Server) Attempt() bool

Attempt 判断是否可以启动

func (*Server) Config

func (e *Server) Config(cfg config.Config)

func (*Server) Endpoint

func (e *Server) Endpoint() *url.URL

func (*Server) Group

func (e *Server) Group(group string, middlewares ...middleware.Middleware) *server.RouterGroup

func (*Server) Handle

func (e *Server) Handle(queue string, obj interface{})

func (*Server) Name

func (e *Server) Name() string

func (*Server) Options

func (e *Server) Options(opts ...Option)

Options 设置参数

func (*Server) ServiceName

func (s *Server) ServiceName() string

ServiceName 服务名称

func (*Server) Start

func (e *Server) Start(ctx context.Context) error

Start 开始

func (*Server) Stop

func (e *Server) Stop(ctx context.Context) error

Shutdown 停止

func (*Server) Type

func (e *Server) Type() string

func (*Server) Use

func (e *Server) Use(middlewares ...middleware.Middleware)

type Setting

type Setting struct {
	Config      Config              `json:"config" yaml:"config"`
	Middlewares []middleware.Config `json:"middlewares"  yaml:"middlewares"`
	Tasks       []*Task             `json:"tasks"  yaml:"tasks"`
}

type Task

type Task struct {
	Queue       string            `json:"queue"`
	Service     string            `json:"service,omitempty"`
	Disable     bool              `json:"disable"`
	Concurrency int               `json:"concurrency,omitempty"`
	Meta        metadata.Metadata `json:"meta,omitempty"`
}

func (*Task) GetService

func (t *Task) GetService() string