rpcbroadcaster

Documentation

Index

• type RPCBroadcaster
  • func NewRPCBroadcaster(log *zap.Logger, sendTimeout time.Duration) *RPCBroadcaster
  • func (r *RPCBroadcaster) NewRPCClient(addr string, method SendMethod, timeout time.Duration, ...) *RPCClient
  • func (r *RPCBroadcaster) Run()
  • func (r *RPCBroadcaster) Shutdown()
• type RPCClient
• type SendMethod

Types

type RPCBroadcaster

type RPCBroadcaster struct {
	Clients   map[string]*RPCClient
	Log       *zap.Logger
	Responses chan request.RawParams
	// contains filtered or unexported fields
}

RPCBroadcaster represent generic RPC broadcaster.

func NewRPCBroadcaster

func NewRPCBroadcaster(log *zap.Logger, sendTimeout time.Duration) *RPCBroadcaster

NewRPCBroadcaster returns new RPC broadcaster instance.

func (*RPCBroadcaster) NewRPCClient

func (r *RPCBroadcaster) NewRPCClient(addr string, method SendMethod, timeout time.Duration, ch chan request.RawParams) *RPCClient

NewRPCClient returns new rpc client for provided address and method.

func (*RPCBroadcaster) Run

func (r *RPCBroadcaster) Run()

Run implements oracle.Broadcaster.

func (*RPCBroadcaster) Shutdown

func (r *RPCBroadcaster) Shutdown()

Shutdown implements oracle.Broadcaster.

type RPCClient

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

RPCClient represent rpc client for a single node.

type SendMethod

type SendMethod func(*client.Client, request.RawParams) error

SendMethod represents rpc method for sending data to other nodes.