network

package
v0.0.0-...-aa59e5a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClientTransport

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

func NewClientTransport

func NewClientTransport(logger *zap.SugaredLogger, config *config.ClientConfig) (*ClientTransport, error)

func (*ClientTransport) Close

func (t *ClientTransport) Close()

func (*ClientTransport) Request

func (t *ClientTransport) Request(dest uint64, data []byte) ([]byte, error)

func (*ClientTransport) Send

func (t *ClientTransport) Send(dest uint64, msg *pb.Request) error

func (*ClientTransport) Start

func (t *ClientTransport) Start() error

type Handler

type Handler func(id uint64, data []byte) ([]byte, error)

type ServerTransport

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

func NewServerTransport

func NewServerTransport(logger *zap.SugaredLogger, config *config.NodeConfig) (*ServerTransport, error)

func (*ServerTransport) Close

func (t *ServerTransport) Close()

func (*ServerTransport) Handle

func (t *ServerTransport) Handle(nodeHandler, clientHandler Handler)

func (*ServerTransport) Send

func (t *ServerTransport) Send(dest uint64, msg *pb.Msg)

func (*ServerTransport) Start

func (t *ServerTransport) Start() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL