plugin

Documentation

Index

• Constants
• func DefaultRegistryApplyCallback(stream apiv1.DeployPluginService_ApplyServer) func(*apiv1.ApplyAction)
• func DefaultRegistryApplyDNSCallback(stream apiv1.DNSPluginService_ApplyDNSServer) func(*apiv1.ApplyAction)
• func DefaultRegistryApplyMonitoringCallback(stream apiv1.MonitoringPluginService_ApplyMonitoringServer) func(*apiv1.ApplyAction)
• func Serve(handler BasicPluginHandler, opts ...ServerOption) error
• type BasicPluginHandler
• type Cleanup
• type CommandPluginHandler
• type DNSPluginHandler
• type DeployHookHandler
• type DeployPluginHandler
• type Handshake
• type LockingPluginHandler
• type LogsPluginHandler
• type MonitoringPluginHandler
• type RegistryOptions
• type RunPluginHandler
• type SecretPluginHandler
• type Server
• type ServerOption
  • func WithRegistryAllowDuplicates(b bool) ServerOption
• type StatePluginHandler

Constants

const ProtocolV1 = "v1"

Functions

func DefaultRegistryApplyCallback

func DefaultRegistryApplyCallback(stream apiv1.DeployPluginService_ApplyServer) func(*apiv1.ApplyAction)

func DefaultRegistryApplyDNSCallback

func DefaultRegistryApplyDNSCallback(stream apiv1.DNSPluginService_ApplyDNSServer) func(*apiv1.ApplyAction)

func DefaultRegistryApplyMonitoringCallback

func DefaultRegistryApplyMonitoringCallback(stream apiv1.MonitoringPluginService_ApplyMonitoringServer) func(*apiv1.ApplyAction)

func Serve

func Serve(handler BasicPluginHandler, opts ...ServerOption) error

Types

type BasicPluginHandler

type BasicPluginHandler interface {
	Init(context.Context, env.Enver, log.Logger, apiv1.HostServiceClient) error
	Start(context.Context, *apiv1.StartRequest) (*apiv1.StartResponse, error)
	ProjectInit(context.Context, *apiv1.ProjectInitRequest) (*apiv1.ProjectInitResponse, error)
}

type Cleanup

type Cleanup interface {
	Cleanup() error
}

type CommandPluginHandler

type CommandPluginHandler interface {
	apiv1.CommandPluginServiceServer
}

type DNSPluginHandler

type DNSPluginHandler interface {
	PlanDNS(context.Context, *registry.Registry, *apiv1.PlanDNSRequest) (*apiv1.PlanDNSResponse, error)
	ApplyDNS(*apiv1.ApplyDNSRequest, *registry.Registry, apiv1.DNSPluginService_ApplyDNSServer) error
}

type DeployHookHandler

type DeployHookHandler interface {
	apiv1.DeployHookServiceServer
}

type DeployPluginHandler

type DeployPluginHandler interface {
	Plan(context.Context, *registry.Registry, *apiv1.PlanRequest) (*apiv1.PlanResponse, error)
	Apply(*apiv1.ApplyRequest, *registry.Registry, apiv1.DeployPluginService_ApplyServer) error
}

type Handshake

type Handshake struct {
	Protocol string `json:"protocol"`
	Addr     string `json:"addr"`
}

type LockingPluginHandler

type LockingPluginHandler interface {
	apiv1.LockingPluginServiceServer
}

type LogsPluginHandler

type LogsPluginHandler interface {
	apiv1.LogsPluginServiceServer
}

type MonitoringPluginHandler

type MonitoringPluginHandler interface {
	PlanMonitoring(context.Context, *registry.Registry, *apiv1.PlanMonitoringRequest) (*apiv1.PlanMonitoringResponse, error)
	ApplyMonitoring(*apiv1.ApplyMonitoringRequest, *registry.Registry, apiv1.MonitoringPluginService_ApplyMonitoringServer) error
}

type RegistryOptions

type RegistryOptions struct {
	AllowDuplicates bool
}

type RunPluginHandler

type RunPluginHandler interface {
	apiv1.RunPluginServiceServer
}

type SecretPluginHandler

type SecretPluginHandler interface {
	apiv1.SecretPluginServiceServer
}

type Server

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

type ServerOption

type ServerOption func(*Server)

func WithRegistryAllowDuplicates

func WithRegistryAllowDuplicates(b bool) ServerOption

type StatePluginHandler

type StatePluginHandler interface {
	apiv1.StatePluginServiceServer
}