Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterCommitLOOPServer ¶
func RegisterCommitLOOPServer(s *grpc.Server, b net.Broker, cfg net.BrokerConfig, impl types.CCIPCommitFactoryGenerator) error
func RegisterExecutionLOOPServer ¶
func RegisterExecutionLOOPServer(s *grpc.Server, b net.Broker, cfg net.BrokerConfig, impl types.CCIPExecutionFactoryGenerator) error
Types ¶
type CommitLOOPClient ¶
type CommitLOOPClient struct {
// hashicorp plugin client
*goplugin.PluginClient
// client to base service
*goplugin.ServiceClient
// contains filtered or unexported fields
}
CommitLOOPClient is a client is run on the core node to connect to the commit LOOP server.
func NewCommitLOOPClient ¶
func NewCommitLOOPClient(broker net.Broker, brokerCfg net.BrokerConfig, conn *grpc.ClientConn) *CommitLOOPClient
func (*CommitLOOPClient) NewCommitFactory ¶
func (c *CommitLOOPClient) NewCommitFactory(ctx context.Context, provider types.CCIPCommitProvider) (types.ReportingPluginFactory, error)
NewCommitFactory creates a new reporting plugin factory client. In practice this client is called by the core node. The reporting plugin factory client is a client to the LOOP server, which is run as an external process via hashicorp plugin. If the given provider is a GRPCClientConn, then the provider is proxied to the to the relayer, which is its own process via hashicorp plugin. If the provider is not a GRPCClientConn, then the provider is a local to the core node. The core must wrap the provider in a grpc server and serve it locally.
type CommitLOOPServer ¶
type CommitLOOPServer struct {
ccippb.UnimplementedCommitFactoryGeneratorServer
*net.BrokerExt
// contains filtered or unexported fields
}
CommitLOOPServer is a server that runs the commit LOOP.
func (*CommitLOOPServer) NewCommitFactory ¶
func (r *CommitLOOPServer) NewCommitFactory(ctx context.Context, request *ccippb.NewCommitFactoryRequest) (*ccippb.NewCommitFactoryResponse, error)
type ExecutionLOOPClient ¶
type ExecutionLOOPClient struct {
// hashicorp plugin client
*goplugin.PluginClient
// client to base service
*goplugin.ServiceClient
// contains filtered or unexported fields
}
ExecutionLOOPClient is a client is run on the core node to connect to the execution LOOP server.
func NewExecutionLOOPClient ¶
func NewExecutionLOOPClient(broker net.Broker, brokerCfg net.BrokerConfig, conn *grpc.ClientConn) *ExecutionLOOPClient
func (*ExecutionLOOPClient) NewExecutionFactory ¶
func (c *ExecutionLOOPClient) NewExecutionFactory(ctx context.Context, srcProvider types.CCIPExecProvider, dstProvider types.CCIPExecProvider, srcChainID int64, dstChainID int64, srcTokenAddress string) (types.ReportingPluginFactory, error)
NewExecutionFactory creates a new reporting plugin factory client. In practice this client is called by the core node. The reporting plugin factory client is a client to the LOOP server, which is run as an external process via hashicorp plugin. If the given provider is a GRPCClientConn, then the provider is proxied to the to the relayer, which is its own process via hashicorp plugin. If the provider is not a GRPCClientConn, then the provider is a local to the core node. The core must wrap the provider in a grpc server and serve it locally.
type ExecutionLOOPServer ¶
type ExecutionLOOPServer struct {
ccippb.UnimplementedExecutionFactoryGeneratorServer
*net.BrokerExt
// contains filtered or unexported fields
}
ExecutionLOOPServer is a server that runs the execution LOOP.
func (*ExecutionLOOPServer) NewExecutionFactory ¶
func (r *ExecutionLOOPServer) NewExecutionFactory(ctx context.Context, request *ccippb.NewExecutionFactoryRequest) (*ccippb.NewExecutionFactoryResponse, error)
Source Files