responses

Documentation

Index

• type Callback
• type Pending
  • func (p *Pending) Add(pr ResponseParams)
  • func (p *Pending) Find(id nonce.ID) (pr *Response)
  • func (p *Pending) FindOlder(t time.Time) (r []*Response)
  • func (p *Pending) GetOldestPending() (pr *Response)
  • func (p *Pending) ProcessAndDelete(id nonce.ID, ifc interface{}, b slice.Bytes) (found bool, e error)
• type Response
• type ResponseParams

Types

type Callback

type Callback func(id nonce.ID, ifc interface{}, b slice.Bytes) (e error)

type Pending

type Pending struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Pending) Add

func (p *Pending) Add(pr ResponseParams)

func (*Pending) Find

func (p *Pending) Find(id nonce.ID) (pr *Response)

func (*Pending) FindOlder

func (p *Pending) FindOlder(t time.Time) (r []*Response)

func (*Pending) GetOldestPending

func (p *Pending) GetOldestPending() (pr *Response)

func (*Pending) ProcessAndDelete

func (p *Pending) ProcessAndDelete(id nonce.ID, ifc interface{},
	b slice.Bytes) (found bool, e error)

ProcessAndDelete runs the callback and post accounting function list and deletes the pending response.

Returns true if it found and deleted a pending response.

type Response

type Response struct {
	ID       nonce.ID
	SentSize int
	Port     uint16
	Billable []crypto.PubBytes
	Return   crypto.PubBytes
	PostAcct []func()
	sessions.Sessions
	Callback Callback
	Time     time.Time
	Success  qu.C
}

type ResponseParams

type ResponseParams struct {
	ID       nonce.ID
	SentSize int
	S        sessions.Sessions
	Billable []crypto.PubBytes
	Ret      crypto.PubBytes
	Port     uint16
	Callback Callback
	PostAcct []func()
}