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) Command(ctx context.Context, req *apiv1.CommandRequest) (*apiv1.CommandResponse, error)
  • func (p *Plugin) DBProxy(ctx context.Context, req *apiv1.CommandRequest) 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) Plan(ctx context.Context, reg *registry.Registry, r *apiv1.PlanRequest) (*apiv1.PlanResponse, 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) SaveState(ctx context.Context, r *apiv1.SaveStateRequest) (*apiv1.SaveStateResponse, error)
  • func (p *Plugin) Start(ctx context.Context, r *apiv1.StartRequest) (*apiv1.StartResponse, error)

Types

type Plugin

type Plugin struct {
	Settings config.Settings
	// 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) Command

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

func (*Plugin) DBProxy

func (p *Plugin) DBProxy(ctx context.Context, req *apiv1.CommandRequest) 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) Plan

func (p *Plugin) Plan(ctx context.Context, reg *registry.Registry, r *apiv1.PlanRequest) (*apiv1.PlanResponse, 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) SaveState

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

func (*Plugin) Start

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