server

Documentation

Index

• Constants
• func Invoke(any interface{}, name string, args ...interface{})
• func NewNode(ctx context.Context)
• type HandlerRepo
• type HealthProtocol
  • func NewHealthProtocol(node *Node, done chan bool) *HealthProtocol
• type IServer
• type Node
  • func (n *Node) Build(ctx context.Context, out host.Host)

Constants

const PROTOCOL_ID = protocol.ID("/twing/1.0/")

Functions

func Invoke

func Invoke(any interface{}, name string, args ...interface{})

func NewNode

func NewNode(ctx context.Context)

Types

type HandlerRepo

type HandlerRepo struct {
	RouteName   string `json:"route_name"`
	HandlerName string `json:"handler_name"`
}

type HealthProtocol

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

func NewHealthProtocol

func NewHealthProtocol(node *Node, done chan bool) *HealthProtocol

type IServer

type IServer interface {
	Build(out host.Host)
}

type Node

type Node struct {
	ID         peer.ID
	Host       host.Host
	GrpcServer grpc.Server
	Reader     chan *fs.StreamIO
}

func (*Node) Build

func (n *Node) Build(ctx context.Context, out host.Host)