module

type GRPCServer ¶

type GRPCServer struct {
	Impl shared.Hook // Hook functions to be called from runtime (module developers must implement this!)
	// contains filtered or unexported fields
}

`module/server.go` implements the gRPC server for receiving from the runtime.

This part works on the module-side and is the gRPC server implementation for the runtime.

func (m *GRPCServer) GetManifest(ctx context.Context, req *proto_common.Empty) (*proto.GetManifestResponse, error)

func (m *GRPCServer) GetStatus(ctx context.Context, req *proto_common.Empty) (*proto.GetStatusResponse, error)

func (m *GRPCServer) OnStage(ctx context.Context, req *proto.OnStageRequest) (*proto_common.Empty, error)

type Plugin ¶

type Plugin struct {
	plugin.NetRPCUnsupportedPlugin

	Impl shared.Hook
}

FlexModule uses hashicorp/go-plugin: So we need to declare a separate Plugin for the runtime and module.

`module/server.go` implements the gRPC server for receiving from the runtime.

`module/client.go` implements the gRPC client for making calls to the runtime.

func (p *Plugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *Plugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error