server

Documentation

Index

• Constants
• type Node
  • func (node *Node) BroadcastMessage(message string)
  • func (node *Node) SayHello(ctx context.Context, stream *hs.HelloRequest) (*hs.HelloReply, error)
  • func (node *Node) SetupClient(name string, addr string)
  • func (node *Node) Start() error
  • func (node *Node) StartListening()

Constants

const KeyPrefix = "grpc-p2p-"

Types

type Node

type Node struct {
	Name string
	Addr string

	SDAddress string
	SDKV      api.KV

	Peers map[string]hs.HelloServiceClient
}

func (*Node) BroadcastMessage

func (node *Node) BroadcastMessage(message string)

func (*Node) SayHello

func (node *Node) SayHello(ctx context.Context, stream *hs.HelloRequest) (*hs.HelloReply, error)

func (*Node) SetupClient

func (node *Node) SetupClient(name string, addr string)

func (*Node) Start

func (node *Node) Start() error

func (*Node) StartListening

func (node *Node) StartListening()