Documentation ¶
Index ¶
- Constants
- func Deliver(chn chain.Chain, data chain.Cid)
- func NewDeliverLetter(p DeliverPayload) *letter.Letter
- func NewReplyTellMeYourWaitLetter(p ReplyTellMeYourWaitPayload) *letter.Letter
- func NewTellMeYoursLetter(p TellMeYourWaitPayload) *letter.Letter
- type ChainX
- func (x *ChainX) Consensus()
- func (x *ChainX) Deal(ltr letter.ILetter) *errors.Error
- func (x *ChainX) GetTopic() []string
- func (x *ChainX) GetWait() *Wait
- func (x *ChainX) IsSameWait(signalling string, serializeStr string) bool
- func (x *ChainX) StartUp() *errors.Error
- func (x *ChainX) Submit(data chain.Cid) *errors.Error
- func (x *ChainX) Tail() *Tail
- type DeliverPayload
- type ReplyTellMeYourWaitPayload
- type Tail
- type TellMeYourWaitPayload
- type Wait
Constants ¶
View Source
const ( TellMeYourWaitTopic = "tell.me.your.wait" ReplyTellMeYourWaitTopic = "reply." + TellMeYourWaitTopic )
View Source
const (
DeliverTopic = "deliver"
)
Variables ¶
This section is empty.
Functions ¶
func NewDeliverLetter ¶
func NewDeliverLetter(p DeliverPayload) *letter.Letter
func NewReplyTellMeYourWaitLetter ¶
func NewReplyTellMeYourWaitLetter(p ReplyTellMeYourWaitPayload) *letter.Letter
func NewTellMeYoursLetter ¶
func NewTellMeYoursLetter(p TellMeYourWaitPayload) *letter.Letter
Types ¶
type ChainX ¶
type ChainX struct { Link []string // contains filtered or unexported fields }
func (*ChainX) IsSameWait ¶
type DeliverPayload ¶
type DeliverPayload struct { Chn chain.Chain `bson:"c" json:"c"` Data chain.Cid `bson:"d" json:"d"` }
func DeliverPayloadOf ¶
func DeliverPayloadOf(str string) (*DeliverPayload, *errors.Error)
type ReplyTellMeYourWaitPayload ¶
type ReplyTellMeYourWaitPayload struct { Chn chain.Chain `bson:"c" json:"c"` Signalling string `bson:"s" json:"s"` BlockNumb int64 `bson:"bn" json:"bn"` BlockSerialize string `bson:"bs" json:"bs"` }
func ReplyTellMeYourWaitPayloadOf ¶
func ReplyTellMeYourWaitPayloadOf(str string) (*ReplyTellMeYourWaitPayload, *errors.Error)
type TellMeYourWaitPayload ¶
type TellMeYourWaitPayload struct { Chn chain.Chain `bson:"c" json:"c"` Signalling string `bson:"s" json:"s"` BlockNumb int64 `bson:"bn" json:"bn"` }
func TellMeYourWaitPayloadOf ¶
func TellMeYourWaitPayloadOf(str string) (*TellMeYourWaitPayload, *errors.Error)
type Wait ¶
type Wait struct {
// contains filtered or unexported fields
}
func (*Wait) GetSignalling ¶
func (*Wait) SomeOneConfirmed ¶
func (w *Wait) SomeOneConfirmed()
Click to show internal directories.
Click to hide internal directories.