client

Documentation

Index

• Constants
• func ValidateHandshake(h *plugin_go.Handshake) error
• type Client
  • func NewClient(log logger.Logger, name, env string, cmd *exec.Cmd, hostAddr string, ...) (*Client, error)
  • func (c *Client) AcquireLocks(ctx context.Context, props map[string]interface{}, lockNames []string, ...) (map[string]string, error)
  • func (c *Client) Apply(ctx context.Context, state *types.StateData, apps []*apiv1.AppPlan, ...) (*apiv1.ApplyDoneResponse, error)
  • func (c *Client) Command(ctx context.Context, req *apiv1.CommandRequest) error
  • func (c *Client) GetState(ctx context.Context, typ string, props map[string]interface{}, lock bool, ...) (ret *apiv1.GetStateResponse_State, err error)
  • func (c *Client) Init(ctx context.Context) error
  • func (c *Client) Plan(ctx context.Context, state *types.StateData, apps []*apiv1.AppPlan, ...) (*apiv1.PlanResponse, error)
  • func (c *Client) ProjectInit(ctx context.Context, name string, deployPlugins, runPlugins []string, ...) (*apiv1.ProjectInitResponse, error)
  • func (c *Client) ReleaseLocks(ctx context.Context, props map[string]interface{}, locks map[string]string) error
  • func (c *Client) ReleaseStateLock(ctx context.Context, typ string, props map[string]interface{}, lockinfo string) error
  • func (c *Client) Run(ctx context.Context, req *apiv1.RunRequest, ...) (*apiv1.RunStartResponse, error)
  • func (c *Client) SaveState(ctx context.Context, state *types.StateData, typ string, ...) (*apiv1.SaveStateResponse, error)
  • func (c *Client) Start(ctx context.Context) error
  • func (c *Client) Stop() error
• type PluginError
  • func (e *PluginError) Error() string
  • func (e *PluginError) Unwrap() error
• type YAMLContext

Constants

const (
	DefaultTimeout = 10 * time.Second
)

Functions

func ValidateHandshake

func ValidateHandshake(h *plugin_go.Handshake) error

Types

type Client

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

func NewClient

func NewClient(log logger.Logger, name, env string, cmd *exec.Cmd, hostAddr string, props map[string]interface{}, yamlContext YAMLContext) (*Client, error)

func (*Client) AcquireLocks

func (c *Client) AcquireLocks(ctx context.Context, props map[string]interface{}, lockNames []string, lockWait time.Duration, yamlContext *YAMLContext) (map[string]string, error)

func (*Client) Apply

func (c *Client) Apply(ctx context.Context, state *types.StateData, apps []*apiv1.AppPlan, deps []*apiv1.DependencyPlan, domains []*apiv1.DomainInfo, args map[string]interface{}, destroy bool, callback func(*apiv1.ApplyAction)) (*apiv1.ApplyDoneResponse, error)

func (*Client) Command

func (c *Client) Command(ctx context.Context, req *apiv1.CommandRequest) error

func (*Client) GetState

func (c *Client) GetState(ctx context.Context, typ string, props map[string]interface{}, lock bool, lockWait time.Duration, skipCreate bool, yamlContext *YAMLContext) (ret *apiv1.GetStateResponse_State, err error)

func (*Client) Init

func (c *Client) Init(ctx context.Context) error

func (*Client) Plan

func (c *Client) Plan(ctx context.Context, state *types.StateData, apps []*apiv1.AppPlan, deps []*apiv1.DependencyPlan, domains []*apiv1.DomainInfo, args map[string]interface{}, verify, destroy bool) (*apiv1.PlanResponse, error)

func (*Client) ProjectInit

func (c *Client) ProjectInit(ctx context.Context, name string, deployPlugins, runPlugins []string, args map[string]interface{}) (*apiv1.ProjectInitResponse, error)

func (*Client) ReleaseLocks

func (c *Client) ReleaseLocks(ctx context.Context, props map[string]interface{}, locks map[string]string) error

func (*Client) ReleaseStateLock

func (c *Client) ReleaseStateLock(ctx context.Context, typ string, props map[string]interface{}, lockinfo string) error

func (*Client) Run

func (c *Client) Run(ctx context.Context, req *apiv1.RunRequest,
	outCh chan<- *apiv1.RunOutputResponse, errCh chan<- error) (*apiv1.RunStartResponse, error)

func (*Client) SaveState

func (c *Client) SaveState(ctx context.Context, state *types.StateData, typ string, props map[string]interface{}) (*apiv1.SaveStateResponse, error)

func (*Client) Start

func (c *Client) Start(ctx context.Context) error

func (*Client) Stop

func (c *Client) Stop() error

type PluginError

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

func (*PluginError) Error

func (e *PluginError) Error() string

func (*PluginError) Unwrap

func (e *PluginError) Unwrap() error

type YAMLContext

type YAMLContext struct {
	Prefix string
	Data   []byte
}