swarm

Documentation

Index

• type Info
  • func (self *Info) Info() *Info
• type Swarm
  • func NewLocalSwarm(datadir, port string) (self *Swarm, err error)
  • func NewSwarm(ctx *node.ServiceContext, backend chequebook.Backend, ...) (self *Swarm, err error)
  • func (self *Swarm) API() *SwarmAPI
  • func (self *Swarm) APIs() []rpc.API
  • func (self *Swarm) Api() *api.Api
  • func (self *Swarm) Protocols() []p2p.Protocol
  • func (self *Swarm) SetChequebook(ctx context.Context) error
  • func (self *Swarm) Start(srv *p2p.Server) error
  • func (self *Swarm) Stop() error
• type SwarmAPI

Types

type Info

type Info struct {
	*api.Config
	*chequebook.Params
}

serialisable info about swarm

func (*Info) Info

func (self *Info) Info() *Info

type Swarm

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

the swarm stack

func NewLocalSwarm

func NewLocalSwarm(datadir, port string) (self *Swarm, err error)

Local swarm without netStore

func NewSwarm

func NewSwarm(ctx *node.ServiceContext, backend chequebook.Backend, ensClient *wtcclient.Client, config *api.Config, swapEnabled, syncEnabled bool, cors string) (self *Swarm, err error)

creates a new swarm service instance implements node.Service

func (*Swarm) API

func (self *Swarm) API() *SwarmAPI

func (*Swarm) APIs

func (self *Swarm) APIs() []rpc.API

implements node.Service Apis returns the RPC Api descriptors the Swarm implementation offers

func (*Swarm) Api

func (self *Swarm) Api() *api.Api

func (*Swarm) Protocols

func (self *Swarm) Protocols() []p2p.Protocol

implements the node.Service interface

func (*Swarm) SetChequebook

func (self *Swarm) SetChequebook(ctx context.Context) error

SetChequebook ensures that the local checquebook is set up on chain.

func (*Swarm) Start

func (self *Swarm) Start(srv *p2p.Server) error

Start is called when the stack is started * starts the network kademlia hive peer management * (starts netStore level 0 api) * starts DPA level 1 api (chunking -> store/retrieve requests) * (starts level 2 api) * starts http proxy server * registers url scheme handlers for bzz, etc * TODO: start subservices like sword, swear, swarmdns

implements the node.Service interface

func (*Swarm) Stop

func (self *Swarm) Stop() error

implements the node.Service interface stops all component services.

type SwarmAPI

type SwarmAPI struct {
	Api     *api.Api
	Backend chequebook.Backend
	PrvKey  *ecdsa.PrivateKey
}