ccip

Documentation

Index

• func RegisterExecutionLOOPServer(s *grpc.Server, b net.Broker, cfg net.BrokerConfig, ...) error
• type ExecutionLOOPClient
  • func NewExecutionLOOPClient(broker net.Broker, brokerCfg net.BrokerConfig, conn *grpc.ClientConn) *ExecutionLOOPClient
  • func (c *ExecutionLOOPClient) NewExecutionFactory(ctx context.Context, provider types.CCIPExecProvider) (types.ReportingPluginFactory, error)
• type ExecutionLOOPServer
  • func (r *ExecutionLOOPServer) NewExecutionFactory(ctx context.Context, request *ccippb.NewExecutionFactoryRequest) (*ccippb.NewExecutionFactoryResponse, error)

Functions

func RegisterExecutionLOOPServer

func RegisterExecutionLOOPServer(s *grpc.Server, b net.Broker, cfg net.BrokerConfig, impl types.CCIPExecutionFactoryGenerator) error

Types

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, provider types.CCIPExecProvider) (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)