mirrors
/
pulumi
mirror of https://github.com/pulumi/pulumi.git
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
pulumi/sdk/proto/go/language.pb.go

630 lines
24 KiB
Go
Raw Permalink Blame History

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: language.proto
package pulumirpc
import (
context "context"
fmt "fmt"
proto "github.com/golang/protobuf/proto"
empty "github.com/golang/protobuf/ptypes/empty"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
type GetRequiredPluginsRequest struct {
Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
Pwd string `protobuf:"bytes,2,opt,name=pwd,proto3" json:"pwd,omitempty"`
Program string `protobuf:"bytes,3,opt,name=program,proto3" json:"program,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetRequiredPluginsRequest) Reset() { *m = GetRequiredPluginsRequest{} }
func (m *GetRequiredPluginsRequest) String() string { return proto.CompactTextString(m) }
func (*GetRequiredPluginsRequest) ProtoMessage() {}
func (*GetRequiredPluginsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_e123c61d1ddd0892, []int{0}
}
func (m *GetRequiredPluginsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetRequiredPluginsRequest.Unmarshal(m, b)
}
func (m *GetRequiredPluginsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetRequiredPluginsRequest.Marshal(b, m, deterministic)
}
func (m *GetRequiredPluginsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetRequiredPluginsRequest.Merge(m, src)
}
func (m *GetRequiredPluginsRequest) XXX_Size() int {
return xxx_messageInfo_GetRequiredPluginsRequest.Size(m)
}
func (m *GetRequiredPluginsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetRequiredPluginsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetRequiredPluginsRequest proto.InternalMessageInfo
func (m *GetRequiredPluginsRequest) GetProject() string {
if m != nil {
return m.Project
}
return ""
}
func (m *GetRequiredPluginsRequest) GetPwd() string {
if m != nil {
return m.Pwd
}
return ""
}
func (m *GetRequiredPluginsRequest) GetProgram() string {
if m != nil {
return m.Program
}
return ""
}
type GetRequiredPluginsResponse struct {
Plugins []*PluginDependency `protobuf:"bytes,1,rep,name=plugins,proto3" json:"plugins,omitempty"`
Providers []*PluginDependency `protobuf:"bytes,2,rep,name=providers,proto3" json:"providers,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetRequiredPluginsResponse) Reset() { *m = GetRequiredPluginsResponse{} }
func (m *GetRequiredPluginsResponse) String() string { return proto.CompactTextString(m) }
func (*GetRequiredPluginsResponse) ProtoMessage() {}
func (*GetRequiredPluginsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_e123c61d1ddd0892, []int{1}
}
func (m *GetRequiredPluginsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetRequiredPluginsResponse.Unmarshal(m, b)
}
func (m *GetRequiredPluginsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetRequiredPluginsResponse.Marshal(b, m, deterministic)
}
func (m *GetRequiredPluginsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetRequiredPluginsResponse.Merge(m, src)
}
func (m *GetRequiredPluginsResponse) XXX_Size() int {
return xxx_messageInfo_GetRequiredPluginsResponse.Size(m)
}
func (m *GetRequiredPluginsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_GetRequiredPluginsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_GetRequiredPluginsResponse proto.InternalMessageInfo
func (m *GetRequiredPluginsResponse) GetPlugins() []*PluginDependency {
if m != nil {
return m.Plugins
}
return nil
}
func (m *GetRequiredPluginsResponse) GetProviders() []*PluginDependency {
if m != nil {
return m.Providers
}
return nil
}
// RunRequest asks the interpreter to execute a program.
type RunRequest struct {
Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
Stack string `protobuf:"bytes,2,opt,name=stack,proto3" json:"stack,omitempty"`
Pwd string `protobuf:"bytes,3,opt,name=pwd,proto3" json:"pwd,omitempty"`
Program string `protobuf:"bytes,4,opt,name=program,proto3" json:"program,omitempty"`
Args []string `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
Config map[string]string `protobuf:"bytes,6,rep,name=config,proto3" json:"config,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
DryRun bool `protobuf:"varint,7,opt,name=dryRun,proto3" json:"dryRun,omitempty"`
Parallel int32 `protobuf:"varint,8,opt,name=parallel,proto3" json:"parallel,omitempty"`
MonitorAddress string `protobuf:"bytes,9,opt,name=monitor_address,json=monitorAddress,proto3" json:"monitor_address,omitempty"`
QueryMode bool `protobuf:"varint,10,opt,name=queryMode,proto3" json:"queryMode,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *RunRequest) Reset() { *m = RunRequest{} }
func (m *RunRequest) String() string { return proto.CompactTextString(m) }
func (*RunRequest) ProtoMessage() {}
func (*RunRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_e123c61d1ddd0892, []int{2}
}
func (m *RunRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RunRequest.Unmarshal(m, b)
}
func (m *RunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RunRequest.Marshal(b, m, deterministic)
}
func (m *RunRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_RunRequest.Merge(m, src)
}
func (m *RunRequest) XXX_Size() int {
return xxx_messageInfo_RunRequest.Size(m)
}
func (m *RunRequest) XXX_DiscardUnknown() {
xxx_messageInfo_RunRequest.DiscardUnknown(m)
}
var xxx_messageInfo_RunRequest proto.InternalMessageInfo
func (m *RunRequest) GetProject() string {
if m != nil {
return m.Project
}
return ""
}
func (m *RunRequest) GetStack() string {
if m != nil {
return m.Stack
}
return ""
}
func (m *RunRequest) GetPwd() string {
if m != nil {
return m.Pwd
}
return ""
}
func (m *RunRequest) GetProgram() string {
if m != nil {
return m.Program
}
return ""
}
func (m *RunRequest) GetArgs() []string {
if m != nil {
return m.Args
}
return nil
}
func (m *RunRequest) GetConfig() map[string]string {
if m != nil {
return m.Config
}
return nil
}
func (m *RunRequest) GetDryRun() bool {
if m != nil {
return m.DryRun
}
return false
}
func (m *RunRequest) GetParallel() int32 {
if m != nil {
return m.Parallel
}
return 0
}
func (m *RunRequest) GetMonitorAddress() string {
if m != nil {
return m.MonitorAddress
}
return ""
}
func (m *RunRequest) GetQueryMode() bool {
if m != nil {
return m.QueryMode
}
return false
}
// RunResponse is the response back from the interpreter/source back to the monitor.
type RunResponse struct {
// An unhandled error if any occurred.
Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
// An error happened. And it was reported to the user. Work should stop immediately
// with nothing further to print to the user. This corresponds to a "result.Bail()"
// value in the 'go' layer.
Bail bool `protobuf:"varint,2,opt,name=bail,proto3" json:"bail,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *RunResponse) Reset() { *m = RunResponse{} }
func (m *RunResponse) String() string { return proto.CompactTextString(m) }
func (*RunResponse) ProtoMessage() {}
func (*RunResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_e123c61d1ddd0892, []int{3}
}
func (m *RunResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RunResponse.Unmarshal(m, b)
}
func (m *RunResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RunResponse.Marshal(b, m, deterministic)
}
func (m *RunResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_RunResponse.Merge(m, src)
}
func (m *RunResponse) XXX_Size() int {
return xxx_messageInfo_RunResponse.Size(m)
}
func (m *RunResponse) XXX_DiscardUnknown() {
xxx_messageInfo_RunResponse.DiscardUnknown(m)
}
var xxx_messageInfo_RunResponse proto.InternalMessageInfo
func (m *RunResponse) GetError() string {
if m != nil {
return m.Error
}
return ""
}
func (m *RunResponse) GetBail() bool {
if m != nil {
return m.Bail
}
return false
}
type StartProviderRequest struct {
// The name of the provider to start.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The version of the provider to start.
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *StartProviderRequest) Reset() { *m = StartProviderRequest{} }
func (m *StartProviderRequest) String() string { return proto.CompactTextString(m) }
func (*StartProviderRequest) ProtoMessage() {}
func (*StartProviderRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_e123c61d1ddd0892, []int{4}
}
func (m *StartProviderRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_StartProviderRequest.Unmarshal(m, b)
}
func (m *StartProviderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_StartProviderRequest.Marshal(b, m, deterministic)
}
func (m *StartProviderRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_StartProviderRequest.Merge(m, src)
}
func (m *StartProviderRequest) XXX_Size() int {
return xxx_messageInfo_StartProviderRequest.Size(m)
}
func (m *StartProviderRequest) XXX_DiscardUnknown() {
xxx_messageInfo_StartProviderRequest.DiscardUnknown(m)
}
var xxx_messageInfo_StartProviderRequest proto.InternalMessageInfo
func (m *StartProviderRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *StartProviderRequest) GetVersion() string {
if m != nil {
return m.Version
}
return ""
}
type StartProviderResponse struct {
// The address at which the provider service is listening.
Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *StartProviderResponse) Reset() { *m = StartProviderResponse{} }
func (m *StartProviderResponse) String() string { return proto.CompactTextString(m) }
func (*StartProviderResponse) ProtoMessage() {}
func (*StartProviderResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_e123c61d1ddd0892, []int{5}
}
func (m *StartProviderResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_StartProviderResponse.Unmarshal(m, b)
}
func (m *StartProviderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_StartProviderResponse.Marshal(b, m, deterministic)
}
func (m *StartProviderResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_StartProviderResponse.Merge(m, src)
}
func (m *StartProviderResponse) XXX_Size() int {
return xxx_messageInfo_StartProviderResponse.Size(m)
}
func (m *StartProviderResponse) XXX_DiscardUnknown() {
xxx_messageInfo_StartProviderResponse.DiscardUnknown(m)
}
var xxx_messageInfo_StartProviderResponse proto.InternalMessageInfo
func (m *StartProviderResponse) GetAddress() string {
if m != nil {
return m.Address
}
return ""
}
func init() {
proto.RegisterType((*GetRequiredPluginsRequest)(nil), "pulumirpc.GetRequiredPluginsRequest")
proto.RegisterType((*GetRequiredPluginsResponse)(nil), "pulumirpc.GetRequiredPluginsResponse")
proto.RegisterType((*RunRequest)(nil), "pulumirpc.RunRequest")
proto.RegisterMapType((map[string]string)(nil), "pulumirpc.RunRequest.ConfigEntry")
proto.RegisterType((*RunResponse)(nil), "pulumirpc.RunResponse")
proto.RegisterType((*StartProviderRequest)(nil), "pulumirpc.StartProviderRequest")
proto.RegisterType((*StartProviderResponse)(nil), "pulumirpc.StartProviderResponse")
}
func init() { proto.RegisterFile("language.proto", fileDescriptor_e123c61d1ddd0892) }
var fileDescriptor_e123c61d1ddd0892 = []byte{
// 561 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x54, 0xdd, 0x6e, 0xd3, 0x4c,
0x10, 0xad, 0xe3, 0xe6, 0xc7, 0xd3, 0xaf, 0xed, 0xa7, 0x55, 0x1b, 0x2d, 0x2e, 0x12, 0xc6, 0x02,
0x91, 0x2b, 0x57, 0x14, 0xf1, 0x13, 0xae, 0x40, 0xb4, 0xaa, 0x90, 0x40, 0xaa, 0x0c, 0xf7, 0x68,
0x63, 0x4f, 0x2c, 0x53, 0x7b, 0xd7, 0x5d, 0xaf, 0x83, 0xfc, 0x12, 0x3c, 0x16, 0x6f, 0xc3, 0x3b,
0x20, 0xaf, 0xd7, 0x49, 0xda, 0xa6, 0xca, 0xdd, 0x9c, 0xf1, 0x99, 0xf1, 0x39, 0x33, 0xbb, 0x0b,
0x07, 0x19, 0xe3, 0x49, 0xc5, 0x12, 0x0c, 0x0a, 0x29, 0x94, 0x20, 0x4e, 0x51, 0x65, 0x55, 0x9e,
0xca, 0x22, 0x72, 0xff, 0x2b, 0xb2, 0x2a, 0x49, 0x79, 0xfb, 0xc1, 0x3d, 0x49, 0x84, 0x48, 0x32,
0x3c, 0xd5, 0x68, 0x56, 0xcd, 0x4f, 0x31, 0x2f, 0x54, 0xdd, 0x7e, 0xf4, 0x19, 0x3c, 0xba, 0x44,
0x15, 0xe2, 0x4d, 0x95, 0x4a, 0x8c, 0xaf, 0x74, 0x5d, 0xd9, 0x40, 0x2c, 0x15, 0xa1, 0x30, 0x2c,
0xa4, 0xf8, 0x89, 0x91, 0xa2, 0x96, 0x67, 0x4d, 0x9c, 0xb0, 0x83, 0xe4, 0x7f, 0xb0, 0x8b, 0x5f,
0x31, 0xed, 0xe9, 0x6c, 0x13, 0x1a, 0x6e, 0x22, 0x59, 0x4e, 0xed, 0x25, 0xb7, 0x81, 0xfe, 0x6f,
0x0b, 0xdc, 0x4d, 0xff, 0x28, 0x0b, 0xc1, 0x4b, 0x24, 0xaf, 0x61, 0xd8, 0xca, 0x2d, 0xa9, 0xe5,
0xd9, 0x93, 0xbd, 0xb3, 0x93, 0x60, 0xe9, 0x24, 0x68, 0xc9, 0xe7, 0x58, 0x20, 0x8f, 0x91, 0x47,
0x75, 0xd8, 0x71, 0xc9, 0x14, 0x9c, 0x42, 0x8a, 0x45, 0x1a, 0xa3, 0x2c, 0x69, 0x6f, 0x7b, 0xe1,
0x8a, 0xed, 0xff, 0xed, 0x01, 0x84, 0x15, 0xdf, 0xee, 0xf2, 0x08, 0xfa, 0xa5, 0x62, 0xd1, 0xb5,
0xf1, 0xd9, 0x82, 0xce, 0xbb, 0xbd, 0xd1, 0xfb, 0xee, 0x2d, 0xef, 0x84, 0xc0, 0x2e, 0x93, 0x49,
0x49, 0xfb, 0x9e, 0x3d, 0x71, 0x42, 0x1d, 0x93, 0x29, 0x0c, 0x22, 0xc1, 0xe7, 0x69, 0x42, 0x07,
0x5a, 0xf6, 0xd3, 0x35, 0xd9, 0x2b, 0x59, 0xc1, 0x27, 0xcd, 0xb9, 0xe0, 0x4a, 0xd6, 0xa1, 0x29,
0x20, 0x63, 0x18, 0xc4, 0xb2, 0x0e, 0x2b, 0x4e, 0x87, 0x9e, 0x35, 0x19, 0x85, 0x06, 0x11, 0x17,
0x46, 0x05, 0x93, 0x2c, 0xcb, 0x30, 0xa3, 0x23, 0xcf, 0x9a, 0xf4, 0xc3, 0x25, 0x26, 0x2f, 0xe0,
0x30, 0x17, 0x3c, 0x55, 0x42, 0xfe, 0x60, 0x71, 0x2c, 0xb1, 0x2c, 0xa9, 0xa3, 0x45, 0x1e, 0x98,
0xf4, 0xc7, 0x36, 0x4b, 0x1e, 0x83, 0x73, 0x53, 0xa1, 0xac, 0xbf, 0x8a, 0x18, 0x29, 0xe8, 0xfe,
0xab, 0x84, 0x3b, 0x85, 0xbd, 0x35, 0x45, 0xcd, 0x10, 0xae, 0xb1, 0x36, 0x03, 0x6b, 0xc2, 0x66,
0x58, 0x0b, 0x96, 0x55, 0xd8, 0x0d, 0x4b, 0x83, 0xf7, 0xbd, 0x77, 0x96, 0xff, 0x16, 0xf6, 0xb4,
0x2f, 0xb3, 0xf0, 0x23, 0xe8, 0xa3, 0x94, 0x42, 0x9a, 0xe2, 0x16, 0x34, 0x93, 0x9a, 0xb1, 0x34,
0xd3, 0xd5, 0xa3, 0x50, 0xc7, 0xfe, 0x39, 0x1c, 0x7d, 0x53, 0x4c, 0xaa, 0x2b, 0xb3, 0xba, 0x6e,
0x63, 0x04, 0x76, 0x39, 0xcb, 0xd1, 0x34, 0xd0, 0x71, 0xb3, 0x83, 0x05, 0xca, 0x32, 0x15, 0xdc,
0x08, 0xe8, 0xa0, 0xff, 0x12, 0x8e, 0xef, 0x74, 0x31, 0x42, 0x28, 0x0c, 0xbb, 0x89, 0x98, 0xc5,
0x1b, 0x78, 0xf6, 0xa7, 0x07, 0x87, 0x5f, 0xcc, 0xf5, 0x0a, 0x2b, 0xae, 0xd2, 0x1c, 0x49, 0x04,
0xe4, 0xfe, 0x29, 0x26, 0xcf, 0xd6, 0x96, 0xf7, 0xe0, 0x45, 0x72, 0x9f, 0x6f, 0x61, 0xb5, 0x82,
0xfc, 0x1d, 0xf2, 0x06, 0xec, 0x66, 0x9f, 0xc7, 0x1b, 0x8f, 0x84, 0x3b, 0xbe, 0x9b, 0x5e, 0xd6,
0x7d, 0x87, 0xfd, 0x5b, 0x1e, 0xc9, 0x93, 0x35, 0xea, 0xa6, 0x19, 0xba, 0xde, 0xc3, 0x84, 0x65,
0xd7, 0x0f, 0xb0, 0x7f, 0x89, 0xaa, 0x55, 0xf9, 0x99, 0xcf, 0x05, 0x19, 0x07, 0xed, 0x5b, 0x12,
0x74, 0x6f, 0x49, 0x70, 0xd1, 0xbc, 0x25, 0xee, 0xf1, 0xbd, 0x9b, 0xd7, 0xd0, 0xfd, 0x9d, 0xd9,
0x40, 0x13, 0x5f, 0xfd, 0x0b, 0x00, 0x00, 0xff, 0xff, 0x87, 0x3d, 0xe5, 0x3f, 0xad, 0x04, 0x00,
0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion6
// LanguageRuntimeClient is the client API for LanguageRuntime service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type LanguageRuntimeClient interface {
// GetRequiredPlugins computes the complete set of anticipated plugins required by a program.
GetRequiredPlugins(ctx context.Context, in *GetRequiredPluginsRequest, opts ...grpc.CallOption) (*GetRequiredPluginsResponse, error)
// Run executes a program and returns its result.
Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
// StartProvider starts a resource provider implemented by the program.
StartProvider(ctx context.Context, in *StartProviderRequest, opts ...grpc.CallOption) (*StartProviderResponse, error)
// GetPluginInfo returns generic information about this plugin, like its version.
GetPluginInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PluginInfo, error)
}
type languageRuntimeClient struct {
cc grpc.ClientConnInterface
}
func NewLanguageRuntimeClient(cc grpc.ClientConnInterface) LanguageRuntimeClient {
return &languageRuntimeClient{cc}
}
func (c *languageRuntimeClient) GetRequiredPlugins(ctx context.Context, in *GetRequiredPluginsRequest, opts ...grpc.CallOption) (*GetRequiredPluginsResponse, error) {
out := new(GetRequiredPluginsResponse)
err := c.cc.Invoke(ctx, "/pulumirpc.LanguageRuntime/GetRequiredPlugins", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *languageRuntimeClient) Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error) {
out := new(RunResponse)
err := c.cc.Invoke(ctx, "/pulumirpc.LanguageRuntime/Run", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *languageRuntimeClient) StartProvider(ctx context.Context, in *StartProviderRequest, opts ...grpc.CallOption) (*StartProviderResponse, error) {
out := new(StartProviderResponse)
err := c.cc.Invoke(ctx, "/pulumirpc.LanguageRuntime/StartProvider", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *languageRuntimeClient) GetPluginInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PluginInfo, error) {
out := new(PluginInfo)
err := c.cc.Invoke(ctx, "/pulumirpc.LanguageRuntime/GetPluginInfo", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// LanguageRuntimeServer is the server API for LanguageRuntime service.
type LanguageRuntimeServer interface {
// GetRequiredPlugins computes the complete set of anticipated plugins required by a program.
GetRequiredPlugins(context.Context, *GetRequiredPluginsRequest) (*GetRequiredPluginsResponse, error)
// Run executes a program and returns its result.
Run(context.Context, *RunRequest) (*RunResponse, error)
// StartProvider starts a resource provider implemented by the program.
StartProvider(context.Context, *StartProviderRequest) (*StartProviderResponse, error)
// GetPluginInfo returns generic information about this plugin, like its version.
GetPluginInfo(context.Context, *empty.Empty) (*PluginInfo, error)
}
// UnimplementedLanguageRuntimeServer can be embedded to have forward compatible implementations.
type UnimplementedLanguageRuntimeServer struct {
}
func (*UnimplementedLanguageRuntimeServer) GetRequiredPlugins(ctx context.Context, req *GetRequiredPluginsRequest) (*GetRequiredPluginsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetRequiredPlugins not implemented")
}
func (*UnimplementedLanguageRuntimeServer) Run(ctx context.Context, req *RunRequest) (*RunResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Run not implemented")
}
func (*UnimplementedLanguageRuntimeServer) StartProvider(ctx context.Context, req *StartProviderRequest) (*StartProviderResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method StartProvider not implemented")
}
func (*UnimplementedLanguageRuntimeServer) GetPluginInfo(ctx context.Context, req *empty.Empty) (*PluginInfo, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetPluginInfo not implemented")
}
func RegisterLanguageRuntimeServer(s *grpc.Server, srv LanguageRuntimeServer) {
s.RegisterService(&_LanguageRuntime_serviceDesc, srv)
}
func _LanguageRuntime_GetRequiredPlugins_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetRequiredPluginsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(LanguageRuntimeServer).GetRequiredPlugins(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pulumirpc.LanguageRuntime/GetRequiredPlugins",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(LanguageRuntimeServer).GetRequiredPlugins(ctx, req.(*GetRequiredPluginsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _LanguageRuntime_Run_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RunRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(LanguageRuntimeServer).Run(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pulumirpc.LanguageRuntime/Run",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(LanguageRuntimeServer).Run(ctx, req.(*RunRequest))
}
return interceptor(ctx, in, info, handler)
}
func _LanguageRuntime_StartProvider_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(StartProviderRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(LanguageRuntimeServer).StartProvider(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pulumirpc.LanguageRuntime/StartProvider",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(LanguageRuntimeServer).StartProvider(ctx, req.(*StartProviderRequest))
}
return interceptor(ctx, in, info, handler)
}
func _LanguageRuntime_GetPluginInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(LanguageRuntimeServer).GetPluginInfo(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pulumirpc.LanguageRuntime/GetPluginInfo",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(LanguageRuntimeServer).GetPluginInfo(ctx, req.(*empty.Empty))
}
return interceptor(ctx, in, info, handler)
}
var _LanguageRuntime_serviceDesc = grpc.ServiceDesc{
ServiceName: "pulumirpc.LanguageRuntime",
HandlerType: (*LanguageRuntimeServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "GetRequiredPlugins",
Handler: _LanguageRuntime_GetRequiredPlugins_Handler,
},
{
MethodName: "Run",
Handler: _LanguageRuntime_Run_Handler,
},
{
MethodName: "StartProvider",
Handler: _LanguageRuntime_StartProvider_Handler,
},
{
MethodName: "GetPluginInfo",
Handler: _LanguageRuntime_GetPluginInfo_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "language.proto",
}
Reference in New Issue View Git Blame Copy Permalink