core

Documentation

Index

• type Config
• type Node
  • func NewNode(cfg Config, ac access.Control, client web3.Client, rawDB storage.KVStore) (*Node, error)
  • func (node *Node) AccessControl() access.Control
  • func (node *Node) Put(msg types.Message) error
  • func (node *Node) Web3Client() web3.Client
• type Processor

Types

type Config

type Config struct {
}

type Node

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

Node defines a w3bstream node

func NewNode

func NewNode(cfg Config, ac access.Control, client web3.Client, rawDB storage.KVStore) (*Node, error)

NewNode creates a new w3bstream node

func (*Node) AccessControl

func (node *Node) AccessControl() access.Control

AccessControl returns the instance of access control

func (*Node) Put

func (node *Node) Put(msg types.Message) error

Put puts message into db after processing

Single node mode, without consensus module

func (*Node) Web3Client

func (node *Node) Web3Client() web3.Client

Web3Client returns the web3 client

type Processor

type Processor interface {
	Process(access.Authentication, storage.KVStore, string, uint8, []byte) error
}

Processor defines an interface which processes an input message with given authentication