connection

Documentation

Index

• func CreateTestConnectionProbeCobraCommand() *cobra.Command
• func CreateTestConnectionServerCobraCommand() *cobra.Command
• type Prober
  • func NewProber(addrss string) *Prober
  • func (p *Prober) RunOnce(ctx context.Context) error
• type RelayerConnectionServer
  • func (rs *RelayerConnectionServer) Probe(ctx context.Context, probeReq *pairingtypes.ProbeRequest) (*pairingtypes.ProbeReply, error)
  • func (rs *RelayerConnectionServer) Relay(ctx context.Context, request *pairingtypes.RelayRequest) (*pairingtypes.RelayReply, error)
  • func (rs *RelayerConnectionServer) RelaySubscribe(request *pairingtypes.RelayRequest, ...) error

Functions

func CreateTestConnectionProbeCobraCommand

func CreateTestConnectionProbeCobraCommand() *cobra.Command

func CreateTestConnectionServerCobraCommand

func CreateTestConnectionServerCobraCommand() *cobra.Command

Types

type Prober

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

func NewProber

func NewProber(addrss string) *Prober

func (*Prober) RunOnce

func (p *Prober) RunOnce(ctx context.Context) error

type RelayerConnectionServer

type RelayerConnectionServer struct {
	pairingtypes.UnimplementedRelayerServer
	// contains filtered or unexported fields
}

func (*RelayerConnectionServer) Probe

func (rs *RelayerConnectionServer) Probe(ctx context.Context, probeReq *pairingtypes.ProbeRequest) (*pairingtypes.ProbeReply, error)

func (*RelayerConnectionServer) Relay

func (rs *RelayerConnectionServer) Relay(ctx context.Context, request *pairingtypes.RelayRequest) (*pairingtypes.RelayReply, error)

func (*RelayerConnectionServer) RelaySubscribe

func (rs *RelayerConnectionServer) RelaySubscribe(request *pairingtypes.RelayRequest, srv pairingtypes.Relayer_RelaySubscribeServer) error