Documentation ¶
Index ¶
- Constants
- Variables
- type Provider
- type ProviderGrpcClient
- func (c *ProviderGrpcClient) ExecuteActions(req *proto.ExecuteActionsRequest) (*proto.ExecuteActionsResponse, error)
- func (c *ProviderGrpcClient) ExecuteFilters(req *proto.ExecuteFiltersRequest) (*proto.ExecuteFiltersResponse, error)
- func (c *ProviderGrpcClient) GetPlugin(req *proto.GetPluginRequest) (*proto.GetPluginResponse, error)
- func (c *ProviderGrpcClient) OnPrClosed(req *proto.OnPrClosedRequest) (*proto.OnPrClosedResponse, error)
- func (c *ProviderGrpcClient) OnPrCreated(req *proto.OnPrCreatedRequest) (*proto.OnPrCreatedResponse, error)
- func (c *ProviderGrpcClient) OnPrMerged(req *proto.OnPrMergedRequest) (*proto.OnPrMergedResponse, error)
- type ProviderGrpcServer
- func (s *ProviderGrpcServer) ExecuteActions(ctx context.Context, request *proto.ExecuteActionsRequest) (*proto.ExecuteActionsResponse, error)
- func (s *ProviderGrpcServer) ExecuteFilters(ctx context.Context, request *proto.ExecuteFiltersRequest) (*proto.ExecuteFiltersResponse, error)
- func (s *ProviderGrpcServer) GetPlugin(ctx context.Context, request *proto.GetPluginRequest) (*proto.GetPluginResponse, error)
- func (s *ProviderGrpcServer) OnPrClosed(_ context.Context, request *proto.OnPrClosedRequest) (*proto.OnPrClosedResponse, error)
- func (s *ProviderGrpcServer) OnPrCreated(_ context.Context, request *proto.OnPrCreatedRequest) (*proto.OnPrCreatedResponse, error)
- func (s *ProviderGrpcServer) OnPrMerged(_ context.Context, request *proto.OnPrMergedRequest) (*proto.OnPrMergedResponse, error)
- type ProviderPlugin
Constants ¶
View Source
const (
ID = "saturn-sync-plugin"
)
Variables ¶
View Source
var Handshake = plugin.HandshakeConfig{
ProtocolVersion: 1,
MagicCookieKey: "SATURN_SYNC_MAGIC_COOKIE",
MagicCookieValue: "9P59IdZaEoZpENXXY2SHuvjczxUVHJaVhGG8RgeIVXfPx6c5wt34g6NLtRNehFT6",
}
View Source
var PluginMap = map[string]plugin.Plugin{ ID: &ProviderPlugin{}, }
Functions ¶
This section is empty.
Types ¶
type Provider ¶
type Provider interface { ExecuteActions(*proto.ExecuteActionsRequest) (*proto.ExecuteActionsResponse, error) ExecuteFilters(*proto.ExecuteFiltersRequest) (*proto.ExecuteFiltersResponse, error) GetPlugin(*proto.GetPluginRequest) (*proto.GetPluginResponse, error) OnPrClosed(*proto.OnPrClosedRequest) (*proto.OnPrClosedResponse, error) OnPrCreated(*proto.OnPrCreatedRequest) (*proto.OnPrCreatedResponse, error) OnPrMerged(*proto.OnPrMergedRequest) (*proto.OnPrMergedResponse, error) }
Provider defines the methods to call remote code via go-plugin.
type ProviderGrpcClient ¶
type ProviderGrpcClient struct {
// contains filtered or unexported fields
}
func (*ProviderGrpcClient) ExecuteActions ¶
func (c *ProviderGrpcClient) ExecuteActions(req *proto.ExecuteActionsRequest) (*proto.ExecuteActionsResponse, error)
func (*ProviderGrpcClient) ExecuteFilters ¶
func (c *ProviderGrpcClient) ExecuteFilters(req *proto.ExecuteFiltersRequest) (*proto.ExecuteFiltersResponse, error)
func (*ProviderGrpcClient) GetPlugin ¶ added in v0.2.0
func (c *ProviderGrpcClient) GetPlugin(req *proto.GetPluginRequest) (*proto.GetPluginResponse, error)
func (*ProviderGrpcClient) OnPrClosed ¶
func (c *ProviderGrpcClient) OnPrClosed(req *proto.OnPrClosedRequest) (*proto.OnPrClosedResponse, error)
func (*ProviderGrpcClient) OnPrCreated ¶
func (c *ProviderGrpcClient) OnPrCreated(req *proto.OnPrCreatedRequest) (*proto.OnPrCreatedResponse, error)
func (*ProviderGrpcClient) OnPrMerged ¶
func (c *ProviderGrpcClient) OnPrMerged(req *proto.OnPrMergedRequest) (*proto.OnPrMergedResponse, error)
type ProviderGrpcServer ¶
type ProviderGrpcServer struct { proto.UnimplementedPluginServiceServer Impl Provider }
func (*ProviderGrpcServer) ExecuteActions ¶
func (s *ProviderGrpcServer) ExecuteActions(ctx context.Context, request *proto.ExecuteActionsRequest) (*proto.ExecuteActionsResponse, error)
func (*ProviderGrpcServer) ExecuteFilters ¶
func (s *ProviderGrpcServer) ExecuteFilters(ctx context.Context, request *proto.ExecuteFiltersRequest) (*proto.ExecuteFiltersResponse, error)
func (*ProviderGrpcServer) GetPlugin ¶ added in v0.2.0
func (s *ProviderGrpcServer) GetPlugin(ctx context.Context, request *proto.GetPluginRequest) (*proto.GetPluginResponse, error)
func (*ProviderGrpcServer) OnPrClosed ¶
func (s *ProviderGrpcServer) OnPrClosed(_ context.Context, request *proto.OnPrClosedRequest) (*proto.OnPrClosedResponse, error)
func (*ProviderGrpcServer) OnPrCreated ¶
func (s *ProviderGrpcServer) OnPrCreated(_ context.Context, request *proto.OnPrCreatedRequest) (*proto.OnPrCreatedResponse, error)
func (*ProviderGrpcServer) OnPrMerged ¶
func (s *ProviderGrpcServer) OnPrMerged(_ context.Context, request *proto.OnPrMergedRequest) (*proto.OnPrMergedResponse, error)
type ProviderPlugin ¶
type ProviderPlugin struct { plugin.Plugin Impl Provider }
ProviderPlugin is the bridge between custom code and go-plugin.
func (*ProviderPlugin) GRPCClient ¶
func (p *ProviderPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
GRPCClient implements GRPCPlugin. https://github.com/hashicorp/go-plugin/blob/8d2aaa458971cba97c3bfec1b0380322e024b514/plugin.go#L36C6-L36C16
func (*ProviderPlugin) GRPCServer ¶
func (p *ProviderPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error
GRPCServer implements GRPCPlugin. https://github.com/hashicorp/go-plugin/blob/8d2aaa458971cba97c3bfec1b0380322e024b514/plugin.go#L36C6-L36C16
Click to show internal directories.
Click to hide internal directories.