twelve

type Expect struct {
	About  string `json:"about"`
	Expect int    `json:"expect"`
	// contains filtered or unexported fields
}

type Job struct {
	Hash    string
	State   State
	Message *Message
	Pre     string
	Nxt     string
}

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

type Message struct {
	Type      Type    `json:"t"`
	Version   Version `json:"v"`
	ID        string  `json:"i"`
	Nonce     int64   `json:"n"`
	Timestamp int64   `json:"tp"`
	Payload   []byte  `json:"pd"`
	Signature string  `json:"s"`
	Peer      *Peer   `json:"pr"`
	// contains filtered or unexported fields
}

type Notifier interface {
	Notify(msg *Message) *errors.Error
}

type Option struct {
	Expect int `json:"expect"`
}

type Payload interface {
	ToBytes() ([]byte, *errors.Error)
}

type Peer struct {
	ID  string `json:"i"`
	PUB ki.PUB `json:"p"`
}

type Queue interface {
	Head() (*Job, *errors.Error)
	Tail() (*Job, *errors.Error)
	Exists(hash string) (*Job, *errors.Error)
	MustGet(hash string) (*Job, *errors.Error)
	Append(msg *Message) (*Job, *errors.Error)
	Remove(hash string) (*Job, *errors.Error)
	Confirm(hash string) (*Job, *errors.Error)
}

type ReplyPayload struct {
	ID        string `json:"i"` // Request ID
	Signature string `json:"s"` // Request Signature
}

type Request struct {
	ID        string `json:"i"`
	Signature string `json:"s"`
}

type RequestPayload struct {
	Action    string `json:"a"`
	Parameter []byte `json:"p"`
	// contains filtered or unexported fields
}

type State int8

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

type Type int32

type Version int32