grpc

Documentation

Index

• Constants
• func FromDataPB(c px.Context, d *datapb.Data) px.Value
• func Load(cmd *exec.Cmd, logger hclog.Logger) (serviceapi.Service, error)
• func NewHclogLogger(log hclog.Logger) px.Logger
• func Serve(c px.Context, s serviceapi.Service)
• func ToDataPB(c px.Context, v px.Value) (data *datapb.Data)
• type Client
  • func (c *Client) Identifier(ctx px.Context) px.TypedName
  • func (c *Client) Invoke(ctx px.Context, identifier, name string, arguments ...px.Value) px.Value
  • func (c *Client) Metadata(ctx px.Context) (typeSet px.TypeSet, definitions []serviceapi.Definition)
  • func (c *Client) State(ctx px.Context, identifier string, parameters px.OrderedMap) px.PuppetObject
• type PluginClient
  • func (a *PluginClient) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, clientConn *grpc.ClientConn) (interface{}, error)
  • func (a *PluginClient) GRPCServer(*plugin.GRPCBroker, *grpc.Server) error
• type Server
  • func (s *Server) Client(*plugin.MuxBroker, *rpc.Client) (interface{}, error)
  • func (s *Server) Do(doer func(c px.Context)) (publicErr *datapb.Data, err error)
  • func (s *Server) GRPCClient(context.Context, *plugin.GRPCBroker, *grpc.ClientConn) (interface{}, error)
  • func (s *Server) GRPCServer(broker *plugin.GRPCBroker, impl *grpc.Server) error
  • func (s *Server) Identity(context.Context, *servicepb.EmptyRequest) (result *datapb.Data, err error)
  • func (s *Server) Invoke(_ context.Context, r *servicepb.InvokeRequest) (result *datapb.Data, err error)
  • func (s *Server) Metadata(_ context.Context, r *servicepb.EmptyRequest) (result *servicepb.MetadataResponse, err error)
  • func (s *Server) Server(*plugin.MuxBroker) (interface{}, error)
  • func (s *Server) State(_ context.Context, r *servicepb.StateRequest) (result *datapb.Data, err error)

Constants

const (
	InvocationError       = `WF_INVOCATION_ERROR`
	ProcInvocationError   = `WF_PROC_INVOCATION_ERROR`
	RemoteInvocationError = `WF_REMOTE_INVOCATION_ERROR`
)

Functions

func FromDataPB

func FromDataPB(c px.Context, d *datapb.Data) px.Value

func Load

func Load(cmd *exec.Cmd, logger hclog.Logger) (serviceapi.Service, error)

Load ...

func NewHclogLogger

func NewHclogLogger(log hclog.Logger) px.Logger

func Serve

func Serve(c px.Context, s serviceapi.Service)

Serve the supplied Server as a go-plugin

func ToDataPB

func ToDataPB(c px.Context, v px.Value) (data *datapb.Data)

Types

type Client

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

func (*Client) Identifier

func (c *Client) Identifier(ctx px.Context) px.TypedName

func (*Client) Invoke

func (c *Client) Invoke(ctx px.Context, identifier, name string, arguments ...px.Value) px.Value

func (*Client) Metadata

func (c *Client) Metadata(ctx px.Context) (typeSet px.TypeSet, definitions []serviceapi.Definition)

func (*Client) State

func (c *Client) State(ctx px.Context, identifier string, parameters px.OrderedMap) px.PuppetObject

type PluginClient

type PluginClient struct {
	plugin.NetRPCUnsupportedPlugin
}

func (*PluginClient) GRPCClient

func (a *PluginClient) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, clientConn *grpc.ClientConn) (interface{}, error)

func (*PluginClient) GRPCServer

func (a *PluginClient) GRPCServer(*plugin.GRPCBroker, *grpc.Server) error

type Server

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

func (*Server) Client

func (s *Server) Client(*plugin.MuxBroker, *rpc.Client) (interface{}, error)

func (*Server) Do

func (s *Server) Do(doer func(c px.Context)) (publicErr *datapb.Data, err error)

func (*Server) GRPCClient

func (s *Server) GRPCClient(context.Context, *plugin.GRPCBroker, *grpc.ClientConn) (interface{}, error)

func (*Server) GRPCServer

func (s *Server) GRPCServer(broker *plugin.GRPCBroker, impl *grpc.Server) error

func (*Server) Identity

func (s *Server) Identity(context.Context, *servicepb.EmptyRequest) (result *datapb.Data, err error)

func (*Server) Invoke

func (s *Server) Invoke(_ context.Context, r *servicepb.InvokeRequest) (result *datapb.Data, err error)

func (*Server) Metadata

func (s *Server) Metadata(_ context.Context, r *servicepb.EmptyRequest) (result *servicepb.MetadataResponse, err error)

func (*Server) Server

func (s *Server) Server(*plugin.MuxBroker) (interface{}, error)

func (*Server) State

func (s *Server) State(_ context.Context, r *servicepb.StateRequest) (result *datapb.Data, err error)