rpc

Documentation

Index

• func Connect(address string) (*grpc.ClientConn, error)
• func ConnectTLS(address string, tlsPath string) (*grpc.ClientConn, error)
• func ConsensusClient(address string) (*grpc.ClientConn, consensus.ClientBackend, error)
• func NodeControllerClient(address string) (*grpc.ClientConn, control.NodeController, error)
• func RegistryClient(address string) (*grpc.ClientConn, registry.Backend, error)
• func SchedulerClient(address string) (*grpc.ClientConn, scheduler.Backend, error)
• func SentryClient(address string, tlsPath string) (*grpc.ClientConn, sentry.Backend, error)
• func StakingClient(address string) (*grpc.ClientConn, staking.Backend, error)

Functions

func Connect

func Connect(address string) (*grpc.ClientConn, error)

Connect - connect to grpc Add grpc.WithBlock() and grpc.WithTimeout() to have dial to constantly try and establish connection

func ConnectTLS

func ConnectTLS(address string, tlsPath string) (*grpc.ClientConn, error)

ConnectTLS connects to server using TLS Certificate

func ConsensusClient

func ConsensusClient(address string) (*grpc.ClientConn,
	consensus.ClientBackend, error)

ConsensusClient - initiate new consensus client

func NodeControllerClient

func NodeControllerClient(address string) (*grpc.ClientConn,
	control.NodeController, error)

NodeControllerClient - initiate new registry client

func RegistryClient

func RegistryClient(address string) (*grpc.ClientConn,
	registry.Backend, error)

RegistryClient - initiate new registry client

func SchedulerClient

func SchedulerClient(address string) (*grpc.ClientConn, scheduler.Backend,
	error)

SchedulerClient - initiate new scheduler client

func SentryClient

func SentryClient(address string, tlsPath string) (*grpc.ClientConn,
	sentry.Backend, error)

SentryClient - initiate new sentry client

func StakingClient

func StakingClient(address string) (*grpc.ClientConn, staking.Backend, error)

StakingClient - initiate new staking client