tcp

Documentation

Index

• type RemoteNodeConfig
• type Server
  • func NewServer(cfg *comms.RPCConfig, t TankaCore, log dex.Logger) (*Server, error)
  • func (s *Server) Connect(ctx context.Context) (*sync.WaitGroup, error)
  • func (s *Server) ConnectBootNode(ctx context.Context, rawCfg json.RawMessage, ...) (tanka.Sender, error)
• type TankaCore

Types

type RemoteNodeConfig

type RemoteNodeConfig struct {
	URL  string `json:"url"`
	Cert []byte `json:"cert"`
}

type Server

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

Server handles HTTP, HTTPS, WebSockets, and Tor communications protocols.

func NewServer

func NewServer(cfg *comms.RPCConfig, t TankaCore, log dex.Logger) (*Server, error)

func (*Server) Connect

func (s *Server) Connect(ctx context.Context) (*sync.WaitGroup, error)

func (*Server) ConnectBootNode

func (s *Server) ConnectBootNode(
	ctx context.Context,
	rawCfg json.RawMessage,
	handleMessage func(cl tanka.Sender, msg *msgjson.Message),
	disconnect func(),
) (tanka.Sender, error)

type TankaCore

type TankaCore interface {
	// Config() *mj.TatankaConfig
	Routes() []string
	HandleMessage(tanka.Sender, *msgjson.Message) *msgjson.Error
}