download

Documentation

Index

• func InitProtocol(env *protocol.P2PEnv)
• type Counter
  • func NewCounter() *Counter
  • func (c *Counter) AddTaskInfo(taskID, pid string, latency time.Duration)
  • func (c *Counter) Release(tasksID string)
  • func (c *Counter) UpdateTaskInfo(taskID, pid string, height, costTime int64)
• type PeerTaskCounter
  • func NewPeerTaskCounter(pid, taskID string) *PeerTaskCounter
  • func (p *PeerTaskCounter) Append(height, costTime int64)
  • func (p *PeerTaskCounter) AppendLatency(latency time.Duration)
  • func (p *PeerTaskCounter) Counter() int64
  • func (p *PeerTaskCounter) Pretty() string
• type Protocol

Functions

func InitProtocol

func InitProtocol(env *protocol.P2PEnv)

InitProtocol initials protocol

Types

type Counter

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

Counter ...

func NewCounter

func NewCounter() *Counter

NewCounter ...

func (*Counter) AddTaskInfo

func (c *Counter) AddTaskInfo(taskID, pid string, latency time.Duration)

AddTaskInfo ...

func (*Counter) Release

func (c *Counter) Release(tasksID string)

Release task by id

func (*Counter) UpdateTaskInfo

func (c *Counter) UpdateTaskInfo(taskID, pid string, height, costTime int64)

UpdateTaskInfo ...

type PeerTaskCounter

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

PeerTaskCounter ...

func NewPeerTaskCounter

func NewPeerTaskCounter(pid, taskID string) *PeerTaskCounter

NewPeerTaskCounter ...

func (*PeerTaskCounter) Append

func (p *PeerTaskCounter) Append(height, costTime int64)

Append add counter info

func (*PeerTaskCounter) AppendLatency

func (p *PeerTaskCounter) AppendLatency(latency time.Duration)

AppendLatency ...

func (*PeerTaskCounter) Counter

func (p *PeerTaskCounter) Counter() int64

Counter ..

func (*PeerTaskCounter) Pretty

func (p *PeerTaskCounter) Pretty() string

Pretty print information

type Protocol

type Protocol struct {
	*protocol.P2PEnv
	// contains filtered or unexported fields
}

Protocol ...