grpc

Documentation

Index

• type GRPCNetwork
  • func New(logger *zap.Logger, dialTimeout, sendTimeout time.Duration) GRPCNetwork
  • func (n GRPCNetwork) BootstrapClient(ctx context.Context, node *types.Node) (bootstrap.BootstrapClient, error)
  • func (n GRPCNetwork) BroadcasterClient(ctx context.Context, node *types.Node) (network.Connection, error)
  • func (n GRPCNetwork) Listen(ctx context.Context, node *types.Node) error
  • func (n GRPCNetwork) RegisterBootstrap(svc bootstrap.Service)
  • func (n GRPCNetwork) RegisterBroadcasterServer(f func(context.Context, []*types.Message) error)

Types

type GRPCNetwork

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

func New

func New(logger *zap.Logger, dialTimeout, sendTimeout time.Duration) GRPCNetwork

func (GRPCNetwork) BootstrapClient

func (n GRPCNetwork) BootstrapClient(ctx context.Context, node *types.Node) (bootstrap.BootstrapClient, error)

func (GRPCNetwork) BroadcasterClient

func (n GRPCNetwork) BroadcasterClient(ctx context.Context, node *types.Node) (network.Connection, error)

func (GRPCNetwork) Listen

func (n GRPCNetwork) Listen(ctx context.Context, node *types.Node) error

func (GRPCNetwork) RegisterBootstrap

func (n GRPCNetwork) RegisterBootstrap(svc bootstrap.Service)

func (GRPCNetwork) RegisterBroadcasterServer

func (n GRPCNetwork) RegisterBroadcasterServer(f func(context.Context, []*types.Message) error)