subscribe

Documentation

Index

• Constants
• Variables
• func ClearSub()
• func Send(name string, value interface{})
• func Sub(name string, ch interface{})
• func UnSub(name string, ch interface{})
• type CaseListItem
• type CentralRouteSub
  • func NewCentralRouteSub() *CentralRouteSub
• type Feed
  • func (f *Feed) Send(value interface{}) (nsent int)
  • func (f *Feed) Subscribe(channel interface{}) Subscription
• type Subscription

Constants

const (
	AddNewPeer     = "addNewPeer"
	DeletePeer     = "deletePeer" // protocol_manager delete peer
	SrvDeletePeer  = "delPeer"    // server delete peer
	NewMinedBlock  = "newMinedBlock"
	NewStableBlock = "newStableBlock"
	NewTx          = "newTx"
	NewConfirm     = "newConfirm"
	FetchConfirms  = "fetchConfirm"
)

Variables

var (
	ErrChType       = errors.New("error of channel type")
	ErrDataType     = errors.New("the type of data can not match with channel")
	ErrNotExistName = errors.New("not exist special subscription")
)

Functions

func ClearSub

func ClearSub()

func Send

func Send(name string, value interface{})

func Sub

func Sub(name string, ch interface{})

func UnSub

func UnSub(name string, ch interface{})

Types

type CaseListItem

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

type CentralRouteSub

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

func NewCentralRouteSub

func NewCentralRouteSub() *CentralRouteSub

type Feed

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

func (*Feed) Send

func (f *Feed) Send(value interface{}) (nsent int)

func (*Feed) Subscribe

func (f *Feed) Subscribe(channel interface{}) Subscription

type Subscription

type Subscription interface {
	Err() <-chan error
	Unsubscribe()
}