ws

Documentation

Index

• Variables
• func ConnectToPeers(ctx context.Context, bs *blc.BlockSet, ss *Sockets, peers []string)
• func ResponseBlockchain(bs *blc.BlockSet, ss *Sockets, msg []byte)
• func WSHandler(bs *blc.BlockSet, ss *Sockets, ws *websocket.Conn)
• type ByIndex
  • func (b ByIndex) Len() int
  • func (b ByIndex) Less(i, j int) bool
  • func (b ByIndex) Swap(i, j int)
• type Sockets
  • func NewSockets() *Sockets
  • func (ss *Sockets) Add(ws *websocket.Conn)
  • func (ss *Sockets) Broadcast(msg []byte)
  • func (ss *Sockets) List() []*websocket.Conn
  • func (ss *Sockets) String() string

Variables

var ProviderSet = wire.NewSet(NewSockets)

Functions

func ConnectToPeers

func ConnectToPeers(ctx context.Context, bs *blc.BlockSet, ss *Sockets, peers []string)

func ResponseBlockchain

func ResponseBlockchain(bs *blc.BlockSet, ss *Sockets, msg []byte)

func WSHandler

func WSHandler(bs *blc.BlockSet, ss *Sockets, ws *websocket.Conn)

Types

type ByIndex

type ByIndex []*blc.Block

func (ByIndex) Len

func (b ByIndex) Len() int

func (ByIndex) Less

func (b ByIndex) Less(i, j int) bool

func (ByIndex) Swap

func (b ByIndex) Swap(i, j int)

type Sockets

type Sockets []*websocket.Conn

func NewSockets

func NewSockets() *Sockets

func (*Sockets) Add

func (ss *Sockets) Add(ws *websocket.Conn)

func (*Sockets) Broadcast

func (ss *Sockets) Broadcast(msg []byte)

func (*Sockets) List

func (ss *Sockets) List() []*websocket.Conn

func (*Sockets) String

func (ss *Sockets) String() string