etcd

Documentation

Index

• func New(cnf *config.Config, endpoint string) (iface.Broker, error)
• type Signature
  • func (s *Signature) Body() ([]byte, error)
  • func (s *Signature) String() string

Functions

func New

func New(cnf *config.Config, endpoint string) (iface.Broker, error)

New ..

Types

type Signature

type Signature struct {
	*tasks.Signature
	CreateAt time.Time `json:"CreatedAt"`
	Score    int64     `json:"Score"` // 写入时间, 队列排序用
	// contains filtered or unexported fields
}

Signature ..

func (*Signature) Body

func (s *Signature) Body() ([]byte, error)

func (*Signature) String

func (s *Signature) String() string