alloter

Documentation

Index

• Constants
• type Body
• type Counter
  • func (m *Counter) Get() int
  • func (m *Counter) Increase()
• type Request
  • func (m *Request) Body() []byte
  • func (m *Request) CanProc() bool
  • 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) GetURL() *url.URL
  • func (m *Request) Monopoly(monopolyJobs cmap.ConcurrentMap) (*monopolyJob, bool, error)
  • func (m *Request) Params() map[string]string
  • func (m *Request) WithContext(ctx sctx.Context)
• type Response
  • 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 Round
  • func (m *Round) CanProc() bool
  • func (m *Round) Current() int
  • func (m *Round) Reduce()
  • func (m *Round) Update(v int)
• type Server
  • func (e *Server) AddJob(jobs ...*xcron.Job) (keys []string, err error)
  • func (e *Server) GetAddr() string
  • func (e *Server) GetProto() string
  • func (e *Server) RemoveJob(keys ...string)
  • func (e *Server) Serve(ctx context.Context) (err error)
  • func (e *Server) Stop(ctx context.Context) error

Constants

const (
	Proto = "alloter"
)

Types

type Body

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

type Counter

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

Counter 任务执行次数

func (*Counter) Get

func (m *Counter) Get() int

Get 获取任务执行次数

func (*Counter) Increase

func (m *Counter) Increase()

Increase 累加执行次数

type Request

type Request struct {
	CalcNextTime time.Time
	// contains filtered or unexported fields
}

Request 处理任务请求

func (*Request) Body

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

func (*Request) CanProc

func (m *Request) CanProc() bool

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) GetURL

func (m *Request) GetURL() *url.URL

GetURL 服务URL

func (*Request) Monopoly

func (m *Request) Monopoly(monopolyJobs cmap.ConcurrentMap) (*monopolyJob, bool, error)

func (*Request) Params

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

func (*Request) WithContext

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

type Response

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

Request 处理任务请求

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 Round

type Round struct {
	Job *xcron.Job
	// contains filtered or unexported fields
}

Round 轮数信息

func (*Round) CanProc

func (m *Round) CanProc() bool

func (*Round) Current

func (m *Round) Current() int

Get 获取任务在几轮后执行

func (*Round) Reduce

func (m *Round) Reduce()

Reduce 减少任务等待轮数

func (*Round) Update

func (m *Round) Update(v int)

Update 更新任务下次执行的轮数

type Server

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

func (*Server) AddJob

func (e *Server) AddJob(jobs ...*xcron.Job) (keys []string, err error)

func (*Server) GetAddr

func (e *Server) GetAddr() string

func (*Server) GetProto

func (e *Server) GetProto() string

func (*Server) RemoveJob

func (e *Server) RemoveJob(keys ...string)

func (*Server) Serve

func (e *Server) Serve(ctx context.Context) (err error)

func (*Server) Stop

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