command

Documentation

Index

• Constants
• type Command
  • func Heartbeat() *Command
  • func Job(data []byte) *Command
  • func Register(channel string) *Command
  • func Remove(channel, id string) *Command
  • func (c *Command) Write(w io.Writer) (int, error)

Constants

const (
	StreamTypeRequest   byte = 1
	StreamTypeJob       byte = 2
	StreamTypeHeartbeat byte = 3
)

Stream command type

const (
	CHeartbeat = "HEARTBEAT"
	CRegister  = "REG"
	CRemove    = "REMOVE"
)

List of available command string

Types

type Command

type Command struct {
	Name []byte
	Body []byte
	Type byte
}

func Heartbeat

func Heartbeat() *Command

Heartbeat command

func Job

func Job(data []byte) *Command

Job command

func Register

func Register(channel string) *Command

Register command new channel to consume

func Remove

func Remove(channel, id string) *Command

Remove command remove job based on id and channel

func (*Command) Write

func (c *Command) Write(w io.Writer) (int, error)