relayerset

Documentation

Index

• type Client
  • func NewRelayerSetClient(log logger.Logger, b *net.BrokerExt, conn grpc.ClientConnInterface) *Client
  • func (k *Client) CloseRelayer(ctx context.Context, relayID types.RelayID) error
  • func (k *Client) Get(ctx context.Context, relayID types.RelayID) (core.Relayer, error)
  • func (k *Client) List(ctx context.Context, relayIDs ...types.RelayID) (map[types.RelayID]core.Relayer, error)
  • func (k *Client) NewPluginProvider(ctx context.Context, relayID types.RelayID, relayArgs core.RelayArgs, ...) (uint32, error)
  • func (k *Client) RelayerHealthReport(ctx context.Context, relayID types.RelayID) (map[string]error, error)
  • func (k *Client) RelayerName(ctx context.Context, relayID types.RelayID) (string, error)
  • func (k *Client) RelayerReady(ctx context.Context, relayID types.RelayID) error
  • func (k *Client) StartRelayer(ctx context.Context, relayID types.RelayID) error
• type Server
  • func NewRelayerSetServer(log logger.Logger, underlying core.RelayerSet, broker *net.BrokerExt) (*Server, net.Resource)
  • func (s *Server) Close() error
  • func (s *Server) CloseRelayer(ctx context.Context, relayID *relayerset.RelayerId) (*emptypb.Empty, error)
  • func (s *Server) Get(ctx context.Context, req *relayerset.GetRelayerRequest) (*relayerset.GetRelayerResponse, error)
  • func (s *Server) List(ctx context.Context, req *relayerset.ListAllRelayersRequest) (*relayerset.ListAllRelayersResponse, error)
  • func (s *Server) NewPluginProvider(ctx context.Context, req *relayerset.NewPluginProviderRequest) (*relayerset.NewPluginProviderResponse, error)
  • func (s *Server) RelayerHealthReport(ctx context.Context, relayID *relayerset.RelayerId) (*relayerset.RelayerHealthReportResponse, error)
  • func (s *Server) RelayerName(ctx context.Context, relayID *relayerset.RelayerId) (*relayerset.RelayerNameResponse, error)
  • func (s *Server) RelayerReady(ctx context.Context, relayID *relayerset.RelayerId) (*emptypb.Empty, error)
  • func (s *Server) StartRelayer(ctx context.Context, relayID *relayerset.RelayerId) (*emptypb.Empty, error)

Types

type Client

type Client struct {
	*net.BrokerExt
	*goplugin.ServiceClient
	// contains filtered or unexported fields
}

func NewRelayerSetClient

func NewRelayerSetClient(log logger.Logger, b *net.BrokerExt, conn grpc.ClientConnInterface) *Client

func (*Client) CloseRelayer

func (k *Client) CloseRelayer(ctx context.Context, relayID types.RelayID) error

func (*Client) Get

func (k *Client) Get(ctx context.Context, relayID types.RelayID) (core.Relayer, error)

func (*Client) List

func (k *Client) List(ctx context.Context, relayIDs ...types.RelayID) (map[types.RelayID]core.Relayer, error)

func (*Client) NewPluginProvider

func (k *Client) NewPluginProvider(ctx context.Context, relayID types.RelayID, relayArgs core.RelayArgs, pluginArgs core.PluginArgs) (uint32, error)

func (*Client) RelayerHealthReport

func (k *Client) RelayerHealthReport(ctx context.Context, relayID types.RelayID) (map[string]error, error)

func (*Client) RelayerName

func (k *Client) RelayerName(ctx context.Context, relayID types.RelayID) (string, error)

func (*Client) RelayerReady

func (k *Client) RelayerReady(ctx context.Context, relayID types.RelayID) error

func (*Client) StartRelayer

func (k *Client) StartRelayer(ctx context.Context, relayID types.RelayID) error

type Server

type Server struct {
	relayerset.UnimplementedRelayerSetServer

	Name string
	// contains filtered or unexported fields
}

func NewRelayerSetServer

func NewRelayerSetServer(log logger.Logger, underlying core.RelayerSet, broker *net.BrokerExt) (*Server, net.Resource)

func (*Server) Close

func (s *Server) Close() error

func (*Server) CloseRelayer

func (s *Server) CloseRelayer(ctx context.Context, relayID *relayerset.RelayerId) (*emptypb.Empty, error)

func (*Server) Get

func (s *Server) Get(ctx context.Context, req *relayerset.GetRelayerRequest) (*relayerset.GetRelayerResponse, error)

func (*Server) List

func (s *Server) List(ctx context.Context, req *relayerset.ListAllRelayersRequest) (*relayerset.ListAllRelayersResponse, error)

func (*Server) NewPluginProvider

func (s *Server) NewPluginProvider(ctx context.Context, req *relayerset.NewPluginProviderRequest) (*relayerset.NewPluginProviderResponse, error)

func (*Server) RelayerHealthReport

func (s *Server) RelayerHealthReport(ctx context.Context, relayID *relayerset.RelayerId) (*relayerset.RelayerHealthReportResponse, error)

func (*Server) RelayerName

func (s *Server) RelayerName(ctx context.Context, relayID *relayerset.RelayerId) (*relayerset.RelayerNameResponse, error)

func (*Server) RelayerReady

func (s *Server) RelayerReady(ctx context.Context, relayID *relayerset.RelayerId) (*emptypb.Empty, error)

func (*Server) StartRelayer

func (s *Server) StartRelayer(ctx context.Context, relayID *relayerset.RelayerId) (*emptypb.Empty, error)