def

Documentation

Index

• type Job
  • func (j *Job) Scan(value interface{}) error
  • func (j Job) Value() (driver.Value, error)
  • func (j *Job) Verify() *errors.Error
• type JobID
  • func NewJobID() JobID
• type Payload
  • func NewPayload() *Payload
  • func PayloadOf(bData []byte) (*Payload, *errors.Error)
  • func (p *Payload) GetBoolean(k string) (bool, *errors.Error)
  • func (p *Payload) GetInt64(k string) (int64, *errors.Error)
  • func (p *Payload) GetString(k string) (string, *errors.Error)
  • func (p *Payload) Set(k string, v string) *Payload
  • func (p *Payload) ToBytes() ([]byte, *errors.Error)

Types

type Job

type Job struct {
	ID      JobID    `bson:"_id,omitempty" json:"id,omitempty"`
	Topic   string   `bson:"topic" json:"topic"`
	Payload *Payload `bson:"payload" json:"payload"`
	Tag     []string `bson:"tag,omitempty" json:"tag,omitempty"`
}

func (*Job) Scan

func (j *Job) Scan(value interface{}) error

func (Job) Value

func (j Job) Value() (driver.Value, error)

func (*Job) Verify

func (j *Job) Verify() *errors.Error

type JobID

type JobID string

func NewJobID

func NewJobID() JobID

type Payload

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

func NewPayload

func NewPayload() *Payload

func PayloadOf

func PayloadOf(bData []byte) (*Payload, *errors.Error)

func (*Payload) GetBoolean

func (p *Payload) GetBoolean(k string) (bool, *errors.Error)

func (*Payload) GetInt64

func (p *Payload) GetInt64(k string) (int64, *errors.Error)

func (*Payload) GetString

func (p *Payload) GetString(k string) (string, *errors.Error)

func (*Payload) Set

func (p *Payload) Set(k string, v string) *Payload

func (*Payload) ToBytes

func (p *Payload) ToBytes() ([]byte, *errors.Error)