rpc

type BasicError ¶

type BasicError struct {
	Message string
}

This is a type that wraps error types so that they can be messaged across RPC channels. Since "error" is an interface, we can't always gob-encode the underlying structure. This is a valid error interface implementer that we will push across.

func NewBasicError(err error) *BasicError

func (e *BasicError) Error() string

type Client ¶

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

Client connects to a Server in order to request plugin implementations for Terraform.

func Dial(network, address string) (*Client, error)

func NewClient(conn io.ReadWriteCloser) (*Client, error)

func (c *Client) Close() error

func (c *Client) ResourceProvider() (terraform.ResourceProvider, error)

func (c *Client) ResourceProvisioner() (terraform.ResourceProvisioner, error)

type ProviderFunc ¶

type ProviderFunc func() terraform.ResourceProvider

ProviderFunc creates terraform.ResourceProviders when they're requested from the server.

type ProvisionerFunc ¶

type ProvisionerFunc func() terraform.ResourceProvisioner

ProvisionerFunc creates terraform.ResourceProvisioners when they're requested from the server.

type ResourceProvider ¶

type ResourceProvider struct {
	Broker *muxBroker
	Client *rpc.Client
	Name   string
}

ResourceProvider is an implementation of terraform.ResourceProvider that communicates over RPC.

func (p *ResourceProvider) Apply(
	info *terraform.InstanceInfo,
	s *terraform.InstanceState,
	d *terraform.InstanceDiff) (*terraform.InstanceState, error)

func (p *ResourceProvider) Configure(c *terraform.ResourceConfig) error

func (p *ResourceProvider) Diff(
	info *terraform.InstanceInfo,
	s *terraform.InstanceState,
	c *terraform.ResourceConfig) (*terraform.InstanceDiff, error)

func (p *ResourceProvider) Input(
	input terraform.UIInput,
	c *terraform.ResourceConfig) (*terraform.ResourceConfig, error)

func (p *ResourceProvider) Refresh(
	info *terraform.InstanceInfo,
	s *terraform.InstanceState) (*terraform.InstanceState, error)

func (p *ResourceProvider) Resources() []terraform.ResourceType

func (p *ResourceProvider) Validate(c *terraform.ResourceConfig) ([]string, []error)

func (p *ResourceProvider) ValidateResource(
	t string, c *terraform.ResourceConfig) ([]string, []error)

type ResourceProviderApplyArgs ¶

type ResourceProviderApplyArgs struct {
	Info  *terraform.InstanceInfo
	State *terraform.InstanceState
	Diff  *terraform.InstanceDiff
}

type ResourceProviderApplyResponse ¶

type ResourceProviderApplyResponse struct {
	State *terraform.InstanceState
	Error *BasicError
}

type ResourceProviderConfigureResponse ¶

type ResourceProviderConfigureResponse struct {
	Error *BasicError
}

type ResourceProviderDiffArgs ¶

type ResourceProviderDiffArgs struct {
	Info   *terraform.InstanceInfo
	State  *terraform.InstanceState
	Config *terraform.ResourceConfig
}

type ResourceProviderDiffResponse ¶

type ResourceProviderDiffResponse struct {
	Diff  *terraform.InstanceDiff
	Error *BasicError
}

type ResourceProviderInputArgs ¶

type ResourceProviderInputArgs struct {
	InputId uint32
	Config  *terraform.ResourceConfig
}

type ResourceProviderInputResponse ¶

type ResourceProviderInputResponse struct {
	Config *terraform.ResourceConfig
	Error  *BasicError
}

type ResourceProviderRefreshArgs ¶

type ResourceProviderRefreshArgs struct {
	Info  *terraform.InstanceInfo
	State *terraform.InstanceState
}

type ResourceProviderRefreshResponse ¶

type ResourceProviderRefreshResponse struct {
	State *terraform.InstanceState
	Error *BasicError
}

type ResourceProviderServer ¶

type ResourceProviderServer struct {
	Broker   *muxBroker
	Provider terraform.ResourceProvider
}

ResourceProviderServer is a net/rpc compatible structure for serving a ResourceProvider. This should not be used directly.

func (s *ResourceProviderServer) Apply(
	args *ResourceProviderApplyArgs,
	result *ResourceProviderApplyResponse) error

func (s *ResourceProviderServer) Configure(
	config *terraform.ResourceConfig,
	reply *ResourceProviderConfigureResponse) error

func (s *ResourceProviderServer) Diff(
	args *ResourceProviderDiffArgs,
	result *ResourceProviderDiffResponse) error

func (s *ResourceProviderServer) Input(
	args *ResourceProviderInputArgs,
	reply *ResourceProviderInputResponse) error

func (s *ResourceProviderServer) Refresh(
	args *ResourceProviderRefreshArgs,
	result *ResourceProviderRefreshResponse) error

func (s *ResourceProviderServer) Resources(
	nothing interface{},
	result *[]terraform.ResourceType) error

func (s *ResourceProviderServer) Validate(
	args *ResourceProviderValidateArgs,
	reply *ResourceProviderValidateResponse) error

func (s *ResourceProviderServer) ValidateResource(
	args *ResourceProviderValidateResourceArgs,
	reply *ResourceProviderValidateResourceResponse) error

type ResourceProviderValidateArgs ¶

type ResourceProviderValidateArgs struct {
	Config *terraform.ResourceConfig
}

type ResourceProviderValidateResourceArgs ¶

type ResourceProviderValidateResourceArgs struct {
	Config *terraform.ResourceConfig
	Type   string
}

type ResourceProviderValidateResourceResponse ¶

type ResourceProviderValidateResourceResponse struct {
	Warnings []string
	Errors   []*BasicError
}

type ResourceProviderValidateResponse ¶

type ResourceProviderValidateResponse struct {
	Warnings []string
	Errors   []*BasicError
}

type ResourceProvisioner ¶

type ResourceProvisioner struct {
	Broker *muxBroker
	Client *rpc.Client
	Name   string
}

ResourceProvisioner is an implementation of terraform.ResourceProvisioner that communicates over RPC.

func (p *ResourceProvisioner) Apply(
	output terraform.UIOutput,
	s *terraform.InstanceState,
	c *terraform.ResourceConfig) error

func (p *ResourceProvisioner) Validate(c *terraform.ResourceConfig) ([]string, []error)

type ResourceProvisionerApplyArgs ¶

type ResourceProvisionerApplyArgs struct {
	OutputId uint32
	State    *terraform.InstanceState
	Config   *terraform.ResourceConfig
}

type ResourceProvisionerApplyResponse ¶

type ResourceProvisionerApplyResponse struct {
	Error *BasicError
}

type ResourceProvisionerServer ¶

type ResourceProvisionerServer struct {
	Broker      *muxBroker
	Provisioner terraform.ResourceProvisioner
}

ResourceProvisionerServer is a net/rpc compatible structure for serving a ResourceProvisioner. This should not be used directly.

func (s *ResourceProvisionerServer) Apply(
	args *ResourceProvisionerApplyArgs,
	result *ResourceProvisionerApplyResponse) error

func (s *ResourceProvisionerServer) Validate(
	args *ResourceProvisionerValidateArgs,
	reply *ResourceProvisionerValidateResponse) error

type ResourceProvisionerValidateArgs ¶

type ResourceProvisionerValidateArgs struct {
	Config *terraform.ResourceConfig
}

type ResourceProvisionerValidateResponse ¶

type ResourceProvisionerValidateResponse struct {
	Warnings []string
	Errors   []*BasicError
}

type Server ¶

type Server struct {
	ProviderFunc    ProviderFunc
	ProvisionerFunc ProvisionerFunc
}

Server listens for network connections and then dispenses interface implementations for Terraform over net/rpc.

func (s *Server) Accept(lis net.Listener)

func (s *Server) ServeConn(conn io.ReadWriteCloser)

type UIInput ¶

type UIInput struct {
	Client *rpc.Client
	Name   string
}

UIInput is an implementatin of terraform.UIInput that communicates over RPC.

func (i *UIInput) Input(opts *terraform.InputOpts) (string, error)

type UIInputInputResponse ¶

type UIInputInputResponse struct {
	Value string
	Error *BasicError
}

type UIInputServer ¶

type UIInputServer struct {
	UIInput terraform.UIInput
}

UIInputServer is a net/rpc compatible structure for serving a UIInputServer. This should not be used directly.

func (s *UIInputServer) Input(
	opts *terraform.InputOpts,
	reply *UIInputInputResponse) error

type UIOutput ¶

type UIOutput struct {
	Client *rpc.Client
	Name   string
}

UIOutput is an implementatin of terraform.UIOutput that communicates over RPC.

func (o *UIOutput) Output(v string)

type UIOutputServer ¶

type UIOutputServer struct {
	UIOutput terraform.UIOutput
}

UIOutputServer is the RPC server for serving UIOutput.

func (s *UIOutputServer) Output(
	v string,
	reply *interface{}) error