xmqc

Documentation

Index

• func DeregisterServer(name string)
• func GetService(queue string) string
• func RegisterServer(resolver ServerResolver)
• type Config
• type Server
  • func NewServer(proto string, router *engine.RouterGroup, cfg config.Config, ...) (Server, error)
• type ServerResolver
• type Task
  • func (s Task) GetBufferSize() int
  • func (t Task) GetConcurrency() int
  • func (s Task) GetMeta() metadata.Metadata
  • func (t Task) GetQueue() string
  • func (t *Task) GetService() string
  • func (s Task) GetVisibilityTimeout() int
• type TaskList

Functions

func DeregisterServer

func DeregisterServer(name string)

Deregister 清理配置适配器

func GetService

func GetService(queue string) string

func RegisterServer

func RegisterServer(resolver ServerResolver)

Register 注册配置文件适配器

Types

type Config

type Config struct {
	Addr   string        `json:"addr"`
	Status engine.Status `json:"status"`
	Proto  string        `json:"proto"`
}

type Server

type Server interface {
	GetProto() string
	GetAddr() string
	Serve(ctx context.Context) (err error)
	Stop(ctx context.Context) error
}

func NewServer

func NewServer(proto string,
	router *engine.RouterGroup,
	cfg config.Config,
	opts ...engine.Option) (Server, error)

NewServer 根据适配器名称及参数返回配置处理器

type ServerResolver

type ServerResolver interface {
	Name() string
	Resolve(name string,
		router *engine.RouterGroup,
		cfg config.Config,
		opts ...engine.Option) (Server, error)
}

ServerResover 定义配置文件转换方法

type Task

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

func (Task) GetBufferSize

func (s Task) GetBufferSize() int

func (Task) GetConcurrency

func (t Task) GetConcurrency() int

func (Task) GetMeta

func (s Task) GetMeta() metadata.Metadata

func (Task) GetQueue

func (t Task) GetQueue() string

func (*Task) GetService

func (t *Task) GetService() string

func (Task) GetVisibilityTimeout

func (s Task) GetVisibilityTimeout() int

type TaskList

type TaskList []*Task