subscribe

package
v1.4.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 5, 2020 License: LGPL-3.0 Imports: 5 Imported by: 2

Documentation

Index

Constants

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

Variables

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

Functions

func ClearSub added in v1.0.2 

func ClearSub()

func Send added in v1.0.1 

func Send(name string, value interface{})

func Sub added in v1.0.1 

func Sub(name string, ch interface{})

func UnSub added in v1.0.1 

func UnSub(name string, ch interface{})

Types

type CaseListItem added in v1.0.1 

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

type CentralRouteSub added in v1.0.1 

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

func NewCentralRouteSub added in v1.0.1 

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()
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.