node

package

v0.1.1 Latest Latest Go to latest Published: Feb 25, 2019 License: MIT Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/AidosKuneen/aknode

Documentation ¶

Index ¶

Constants
Variables
func CheckAddTx(ctx context.Context, s *setting.Setting, tr *tx.Transaction, typ tx.Type) error
func CheckAddTxs(ctx context.Context, s *setting.Setting, trs []*imesh.TxWithType) error
func ConnSize() int
func GetBanned() map[string][]time.Time
func GetPeerlist() []msg.Addr
func RegisterTxNotifier(n chan []tx.Hash)
func RunMiner(ctx context.Context, s *setting.Setting)
func Start(ctx context.Context, setting *setting.Setting, debug bool) (net.Listener, error)
func WriteAll(s *setting.Setting, m proto.Marshaler, cmd msg.Command)
type Broadcaster
- func NewBroadcaster(s *setting.Setting) *Broadcaster
- func (bc *Broadcaster) GetTx(h tx.Hash)
- func (bc *Broadcaster) Send(p *akconsensus.Message)
type NodesDB
- func NewPopulatedNodesDB(r randyNode, easy bool) *NodesDB

Constants ¶

View Source

const (
	//BanTime is time to be banned
	BanTime = time.Hour
)

Variables ¶

View Source

var (
	ErrInvalidLengthNode = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNode   = fmt.Errorf("proto: integer overflow")
)

Functions ¶

func CheckAddTx ¶

func CheckAddTx(ctx context.Context, s *setting.Setting, tr *tx.Transaction, typ tx.Type) error

CheckAddTx adds trs into imeash if they are already resolved. If not adds to search cron.

func CheckAddTxs ¶

func CheckAddTxs(ctx context.Context, s *setting.Setting, trs []*imesh.TxWithType) error

CheckAddTxs adds trs into imeash if they are already resolved. If not adds to search cron.

func ConnSize ¶

func ConnSize() int

ConnSize returns number of connection peers.

func GetBanned ¶

func GetBanned() map[string][]time.Time

GetBanned returns a banned list.

func GetPeerlist ¶

func GetPeerlist() []msg.Addr

GetPeerlist returns a peer list.

func RegisterTxNotifier ¶

func RegisterTxNotifier(n chan []tx.Hash)

RegisterTxNotifier registers a notifier for resolved txs.

func RunMiner ¶

func RunMiner(ctx context.Context, s *setting.Setting)

RunMiner runs a miner

func Start ¶

func Start(ctx context.Context, setting *setting.Setting, debug bool) (net.Listener, error)

Start starts a node server.

func WriteAll ¶

func WriteAll(s *setting.Setting, m proto.Marshaler, cmd msg.Command)

WriteAll writes a command to all connected peers.

Types ¶

type Broadcaster ¶

type Broadcaster struct {
	Setting *setting.Setting
}

Broadcaster is for consensus to communicate with peers.

func NewBroadcaster ¶

func NewBroadcaster(s *setting.Setting) *Broadcaster

NewBroadcaster returns a ConsensusPeer object.

func (*Broadcaster) GetTx ¶

func (bc *Broadcaster) GetTx(h tx.Hash)

GetTx tryies to get a tx.

func (*Broadcaster) Send ¶

func (bc *Broadcaster) Send(p *akconsensus.Message)

Send broadcasts a Message..

type NodesDB ¶

type NodesDB struct {
	Addrs []*msg.Addr `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
}

func NewPopulatedNodesDB ¶

func NewPopulatedNodesDB(r randyNode, easy bool) *NodesDB

func (*NodesDB) Descriptor ¶

func (*NodesDB) Descriptor() ([]byte, []int)

func (*NodesDB) Equal ¶

func (this *NodesDB) Equal(that interface{}) bool

func (*NodesDB) Marshal ¶

func (m *NodesDB) Marshal() (dAtA []byte, err error)

func (*NodesDB) MarshalTo ¶

func (m *NodesDB) MarshalTo(dAtA []byte) (int, error)

func (*NodesDB) ProtoMessage ¶

func (*NodesDB) ProtoMessage()

func (*NodesDB) Reset ¶

func (m *NodesDB) Reset()

func (*NodesDB) Size ¶

func (m *NodesDB) Size() (n int)

func (*NodesDB) String ¶

func (m *NodesDB) String() string

func (*NodesDB) Unmarshal ¶

func (m *NodesDB) Unmarshal(dAtA []byte) error

func (*NodesDB) XXX_DiscardUnknown ¶

func (m *NodesDB) XXX_DiscardUnknown()

func (*NodesDB) XXX_Marshal ¶

func (m *NodesDB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodesDB) XXX_Merge ¶

func (dst *NodesDB) XXX_Merge(src proto.Message)

func (*NodesDB) XXX_Size ¶

func (m *NodesDB) XXX_Size() int

func (*NodesDB) XXX_Unmarshal ¶

func (m *NodesDB) XXX_Unmarshal(b []byte) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL