plugin

Documentation

Index

• type Plugin
  • func NewPlugin() *Plugin
  • func (p *Plugin) AcquireLocks(r *apiv1.AcquireLocksRequest, ...) error
  • func (p *Plugin) Apply(r *apiv1.ApplyRequest, reg *registry.Registry, ...) error
  • func (p *Plugin) ApplyMonitoring(r *apiv1.ApplyMonitoringRequest, reg *registry.Registry, ...) error
  • func (p *Plugin) Command(ctx context.Context, req *apiv1.CommandRequest) (*apiv1.CommandResponse, error)
  • func (p *Plugin) CreateServiceAccount(ctx context.Context, req *apiv1.CommandRequest) error
  • func (p *Plugin) DBDump(ctx context.Context, req *apiv1.CommandRequest) error
  • func (p *Plugin) DBProxy(ctx context.Context, req *apiv1.CommandRequest) error
  • func (p *Plugin) DBRestore(ctx context.Context, req *apiv1.CommandRequest) error
  • func (p *Plugin) DeleteSecret(ctx context.Context, req *apiv1.DeleteSecretRequest) (*apiv1.DeleteSecretResponse, error)
  • func (p *Plugin) DeleteSecrets(ctx context.Context, req *apiv1.DeleteSecretsRequest) (*apiv1.DeleteSecretsResponse, error)
  • func (p *Plugin) GetSecret(ctx context.Context, req *apiv1.GetSecretRequest) (*apiv1.GetSecretResponse, error)
  • func (p *Plugin) GetSecrets(ctx context.Context, req *apiv1.GetSecretsRequest) (*apiv1.GetSecretsResponse, error)
  • func (p *Plugin) GetState(r *apiv1.GetStateRequest, stream apiv1.StatePluginService_GetStateServer) error
  • func (p *Plugin) Init(ctx context.Context, e env.Enver, l log.Logger, cli apiv1.HostServiceClient) error
  • func (p *Plugin) Logs(r *apiv1.LogsRequest, srv apiv1.LogsPluginService_LogsServer) error
  • func (p *Plugin) Plan(ctx context.Context, reg *registry.Registry, r *apiv1.PlanRequest) (*apiv1.PlanResponse, error)
  • func (p *Plugin) PlanMonitoring(ctx context.Context, reg *registry.Registry, r *apiv1.PlanMonitoringRequest) (*apiv1.PlanMonitoringResponse, error)
  • func (p *Plugin) PluginContext() *config.PluginContext
  • func (p *Plugin) ProjectInit(ctx context.Context, r *apiv1.ProjectInitRequest) (*apiv1.ProjectInitResponse, error)
  • func (p *Plugin) ReleaseLocks(ctx context.Context, r *apiv1.ReleaseLocksRequest) (*apiv1.ReleaseLocksResponse, error)
  • func (p *Plugin) ReleaseStateLock(ctx context.Context, r *apiv1.ReleaseStateLockRequest) (*apiv1.ReleaseStateLockResponse, error)
  • func (p *Plugin) ReplaceSecrets(ctx context.Context, req *apiv1.ReplaceSecretsRequest) (*apiv1.ReplaceSecretsResponse, error)
  • func (p *Plugin) SaveState(ctx context.Context, r *apiv1.SaveStateRequest) (*apiv1.SaveStateResponse, error)
  • func (p *Plugin) SetSecret(ctx context.Context, req *apiv1.SetSecretRequest) (*apiv1.SetSecretResponse, error)
  • func (p *Plugin) Start(ctx context.Context, r *apiv1.StartRequest) (*apiv1.StartResponse, error)

Types

type Plugin

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

func NewPlugin

func NewPlugin() *Plugin

func (*Plugin) AcquireLocks

func (p *Plugin) AcquireLocks(r *apiv1.AcquireLocksRequest, stream apiv1.LockingPluginService_AcquireLocksServer) error

func (*Plugin) Apply

func (p *Plugin) Apply(r *apiv1.ApplyRequest, reg *registry.Registry, stream apiv1.DeployPluginService_ApplyServer) error

func (*Plugin) ApplyMonitoring

func (p *Plugin) ApplyMonitoring(r *apiv1.ApplyMonitoringRequest, reg *registry.Registry, stream apiv1.MonitoringPluginService_ApplyMonitoringServer) error

func (*Plugin) Command

func (p *Plugin) Command(ctx context.Context, req *apiv1.CommandRequest) (*apiv1.CommandResponse, error)

func (*Plugin) CreateServiceAccount

func (p *Plugin) CreateServiceAccount(ctx context.Context, req *apiv1.CommandRequest) error

func (*Plugin) DBDump

func (p *Plugin) DBDump(ctx context.Context, req *apiv1.CommandRequest) error

func (*Plugin) DBProxy

func (p *Plugin) DBProxy(ctx context.Context, req *apiv1.CommandRequest) error

func (*Plugin) DBRestore

func (p *Plugin) DBRestore(ctx context.Context, req *apiv1.CommandRequest) error

func (*Plugin) DeleteSecret

func (p *Plugin) DeleteSecret(ctx context.Context, req *apiv1.DeleteSecretRequest) (*apiv1.DeleteSecretResponse, error)

func (*Plugin) DeleteSecrets

func (p *Plugin) DeleteSecrets(ctx context.Context, req *apiv1.DeleteSecretsRequest) (*apiv1.DeleteSecretsResponse, error)

func (*Plugin) GetSecret

func (p *Plugin) GetSecret(ctx context.Context, req *apiv1.GetSecretRequest) (*apiv1.GetSecretResponse, error)

func (*Plugin) GetSecrets

func (p *Plugin) GetSecrets(ctx context.Context, req *apiv1.GetSecretsRequest) (*apiv1.GetSecretsResponse, error)

func (*Plugin) GetState

func (p *Plugin) GetState(r *apiv1.GetStateRequest, stream apiv1.StatePluginService_GetStateServer) error

func (*Plugin) Init

func (p *Plugin) Init(ctx context.Context, e env.Enver, l log.Logger, cli apiv1.HostServiceClient) error

func (*Plugin) Logs

func (p *Plugin) Logs(r *apiv1.LogsRequest, srv apiv1.LogsPluginService_LogsServer) error

func (*Plugin) Plan

func (p *Plugin) Plan(ctx context.Context, reg *registry.Registry, r *apiv1.PlanRequest) (*apiv1.PlanResponse, error)

func (*Plugin) PlanMonitoring

func (p *Plugin) PlanMonitoring(ctx context.Context, reg *registry.Registry, r *apiv1.PlanMonitoringRequest) (*apiv1.PlanMonitoringResponse, error)

func (*Plugin) PluginContext

func (p *Plugin) PluginContext() *config.PluginContext

func (*Plugin) ProjectInit

func (p *Plugin) ProjectInit(ctx context.Context, r *apiv1.ProjectInitRequest) (*apiv1.ProjectInitResponse, error)

func (*Plugin) ReleaseLocks

func (p *Plugin) ReleaseLocks(ctx context.Context, r *apiv1.ReleaseLocksRequest) (*apiv1.ReleaseLocksResponse, error)

func (*Plugin) ReleaseStateLock

func (p *Plugin) ReleaseStateLock(ctx context.Context, r *apiv1.ReleaseStateLockRequest) (*apiv1.ReleaseStateLockResponse, error)

func (*Plugin) ReplaceSecrets

func (p *Plugin) ReplaceSecrets(ctx context.Context, req *apiv1.ReplaceSecretsRequest) (*apiv1.ReplaceSecretsResponse, error)

func (*Plugin) SaveState

func (p *Plugin) SaveState(ctx context.Context, r *apiv1.SaveStateRequest) (*apiv1.SaveStateResponse, error)

func (*Plugin) SetSecret

func (p *Plugin) SetSecret(ctx context.Context, req *apiv1.SetSecretRequest) (*apiv1.SetSecretResponse, error)

func (*Plugin) Start

func (p *Plugin) Start(ctx context.Context, r *apiv1.StartRequest) (*apiv1.StartResponse, error)