gateway

package

v0.9.4 Latest Latest Go to latest Published: Sep 2, 2025 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/smartcontractkit/chainlink-common

Links

Open Source Insights

Documentation ¶

Index ¶

type GatewayConnectorClient
- func NewGatewayConnectorClient(cc grpc.ClientConnInterface, b *net.BrokerExt) *GatewayConnectorClient
type GatewayConnectorHandlerClient
- func NewGatewayConnectorHandlerClient(cc grpc.ClientConnInterface) *GatewayConnectorHandlerClient
- func (c GatewayConnectorHandlerClient) HandleGatewayMessage(ctx context.Context, gatewayID string, req *jsonrpc.Request[json.RawMessage]) error
- func (c GatewayConnectorHandlerClient) ID(ctx context.Context) (string, error)
type GatewayConnectorHandlerServer
- func NewGatewayConnectorHandlerServer(impl core.GatewayConnectorHandler) *GatewayConnectorHandlerServer
- func (s GatewayConnectorHandlerServer) HandleGatewayMessage(ctx context.Context, req *pb.SendMessageRequest) (*emptypb.Empty, error)
type GatewayConnectorServer
- func NewGatewayConnectorServer(b *net.BrokerExt, impl core.GatewayConnector) *GatewayConnectorServer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type GatewayConnectorClient ¶

type GatewayConnectorClient struct {
	*net.BrokerExt
	// contains filtered or unexported fields
}

func NewGatewayConnectorClient ¶

func NewGatewayConnectorClient(cc grpc.ClientConnInterface, b *net.BrokerExt) *GatewayConnectorClient

func (GatewayConnectorClient) AddHandler ¶

func (c GatewayConnectorClient) AddHandler(ctx context.Context, methods []string, handler core.GatewayConnectorHandler) error

func (GatewayConnectorClient) AwaitConnection ¶

func (c GatewayConnectorClient) AwaitConnection(ctx context.Context, gatewayID string) error

func (GatewayConnectorClient) DonID ¶

func (c GatewayConnectorClient) DonID(ctx context.Context) (string, error)

func (GatewayConnectorClient) GatewayIDs ¶

func (c GatewayConnectorClient) GatewayIDs(ctx context.Context) ([]string, error)

func (GatewayConnectorClient) SendToGateway ¶

func (c GatewayConnectorClient) SendToGateway(ctx context.Context, gatewayID string, resp *jsonrpc.Response[json.RawMessage]) error

func (GatewayConnectorClient) SignMessage ¶

func (c GatewayConnectorClient) SignMessage(ctx context.Context, msg []byte) ([]byte, error)

type GatewayConnectorHandlerClient ¶

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

func NewGatewayConnectorHandlerClient ¶

func NewGatewayConnectorHandlerClient(cc grpc.ClientConnInterface) *GatewayConnectorHandlerClient

func (GatewayConnectorHandlerClient) HandleGatewayMessage ¶

func (c GatewayConnectorHandlerClient) HandleGatewayMessage(ctx context.Context, gatewayID string, req *jsonrpc.Request[json.RawMessage]) error

func (GatewayConnectorHandlerClient) ID ¶

func (c GatewayConnectorHandlerClient) ID(ctx context.Context) (string, error)

type GatewayConnectorHandlerServer ¶

type GatewayConnectorHandlerServer struct {
	pb.UnimplementedGatewayConnectorHandlerServer
	*net.BrokerExt
	// contains filtered or unexported fields
}

func NewGatewayConnectorHandlerServer ¶

func NewGatewayConnectorHandlerServer(impl core.GatewayConnectorHandler) *GatewayConnectorHandlerServer

func (GatewayConnectorHandlerServer) HandleGatewayMessage ¶

func (s GatewayConnectorHandlerServer) HandleGatewayMessage(ctx context.Context, req *pb.SendMessageRequest) (*emptypb.Empty, error)

type GatewayConnectorServer ¶

type GatewayConnectorServer struct {
	pb.UnimplementedGatewayConnectorServer
	*net.BrokerExt
	// contains filtered or unexported fields
}

func NewGatewayConnectorServer ¶

func NewGatewayConnectorServer(b *net.BrokerExt, impl core.GatewayConnector) *GatewayConnectorServer

func (GatewayConnectorServer) AddHandler ¶

func (s GatewayConnectorServer) AddHandler(ctx context.Context, req *pb.AddHandlerRequest) (*emptypb.Empty, error)

func (GatewayConnectorServer) AwaitConnection ¶

func (s GatewayConnectorServer) AwaitConnection(ctx context.Context, req *pb.GatewayIDRequest) (*emptypb.Empty, error)

func (GatewayConnectorServer) DonID ¶

func (s GatewayConnectorServer) DonID(ctx context.Context, _ *emptypb.Empty) (*pb.DonIDReply, error)

func (GatewayConnectorServer) GatewayIDs ¶

func (s GatewayConnectorServer) GatewayIDs(ctx context.Context, _ *emptypb.Empty) (*pb.GatewayIDsReply, error)

func (GatewayConnectorServer) SendToGateway ¶

func (s GatewayConnectorServer) SendToGateway(ctx context.Context, req *pb.SendMessageRequest) (*emptypb.Empty, error)

func (GatewayConnectorServer) SignMessage ¶

func (s GatewayConnectorServer) SignMessage(ctx context.Context, req *pb.SignMessageRequest) (*pb.SignMessageReply, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL