shared

Documentation

Index

• Constants
• Variables
• type GRPCClient
  • func (c *GRPCClient) BuildHook(hookName string, info component.HookBuildData) (*component.Hook, error)
  • func (c *GRPCClient) GetHooksMetadata() ([]resource.HookMetadata, error)
  • func (c *GRPCClient) GetPipelineType() (string, error)
• type GRPCServer
  • func (s *GRPCServer) BuildHook(_ context.Context, in *proto.BuildHookRequest) (*proto.BuildHookResponse, error)
  • func (s *GRPCServer) GetHooksMetaData(_ context.Context, _ *proto.Empty) (*proto.GetHooksMetaDataResponse, error)
  • func (s *GRPCServer) GetPipelineType(_ context.Context, _ *proto.Empty) (*proto.GetPipelineTypeResponse, error)
• type HookFactoryPlugin
  • func (hfp *HookFactoryPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
  • func (hfp *HookFactoryPlugin) GRPCServer(_ *plugin.GRPCBroker, s *grpc.Server) error

Constants

const (
	PluginTypeGRPC = "grpc"
)

Variables

var Handshake = plugin.HandshakeConfig{
	ProtocolVersion:  1,
	MagicCookieKey:   "NAUTES_PIPELINE_PLUGIN",
	MagicCookieValue: "hereIsNautesPipeline",
}

var PluginMap = map[string]plugin.Plugin{
	PluginTypeGRPC: &HookFactoryPlugin{},
}

Types

type GRPCClient

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

func (*GRPCClient) BuildHook

func (c *GRPCClient) BuildHook(hookName string, info component.HookBuildData) (*component.Hook, error)

func (*GRPCClient) GetHooksMetadata

func (c *GRPCClient) GetHooksMetadata() ([]resource.HookMetadata, error)

func (*GRPCClient) GetPipelineType

func (c *GRPCClient) GetPipelineType() (string, error)

type GRPCServer

type GRPCServer struct {
	Impl component.HookFactory
	*proto.UnimplementedHookFactoryServer
}

func (*GRPCServer) BuildHook

func (s *GRPCServer) BuildHook(_ context.Context, in *proto.BuildHookRequest) (*proto.BuildHookResponse, error)

func (*GRPCServer) GetHooksMetaData

func (s *GRPCServer) GetHooksMetaData(_ context.Context, _ *proto.Empty) (*proto.GetHooksMetaDataResponse, error)

func (*GRPCServer) GetPipelineType

func (s *GRPCServer) GetPipelineType(_ context.Context, _ *proto.Empty) (*proto.GetPipelineTypeResponse, error)

type HookFactoryPlugin

type HookFactoryPlugin struct {
	plugin.Plugin
	Impl component.HookFactory
}

func (*HookFactoryPlugin) GRPCClient

func (hfp *HookFactoryPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (*HookFactoryPlugin) GRPCServer

func (hfp *HookFactoryPlugin) GRPCServer(_ *plugin.GRPCBroker, s *grpc.Server) error