// Copyright (c) HashiCorp, Inc. // SPDX-License-Identifier: MPL-2.0 // Terraform Plugin RPC protocol version 5.9 // // This file defines version 5.9 of the RPC protocol. To implement a plugin // against this protocol, copy this definition into your own codebase and // use protoc to generate stubs for your target language. // // This file will not be updated. Any minor versions of protocol 5 to follow // should copy this file and modify the copy while maintaing backwards // compatibility. Breaking changes, if any are required, will come // in a subsequent major version with its own separate proto definition. // // Note that only the proto files included in a release tag of Terraform are // official protocol releases. Proto files taken from other commits may include // incomplete changes or features that did not make it into a final release. // In all reasonable cases, plugin developers should take the proto file from // the tag of the most recent release of Terraform, and not from the main // branch or any other development branch. // // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 // - protoc v6.32.1 // source: tfplugin5.proto package tfplugin5 import ( context "context" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" ) // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 const ( Provider_GetMetadata_FullMethodName = "/tfplugin5.Provider/GetMetadata" Provider_GetSchema_FullMethodName = "/tfplugin5.Provider/GetSchema" Provider_GetResourceIdentitySchemas_FullMethodName = "/tfplugin5.Provider/GetResourceIdentitySchemas" Provider_PrepareProviderConfig_FullMethodName = "/tfplugin5.Provider/PrepareProviderConfig" Provider_ValidateResourceTypeConfig_FullMethodName = "/tfplugin5.Provider/ValidateResourceTypeConfig" Provider_ValidateDataSourceConfig_FullMethodName = "/tfplugin5.Provider/ValidateDataSourceConfig" Provider_UpgradeResourceState_FullMethodName = "/tfplugin5.Provider/UpgradeResourceState" Provider_UpgradeResourceIdentity_FullMethodName = "/tfplugin5.Provider/UpgradeResourceIdentity" Provider_Configure_FullMethodName = "/tfplugin5.Provider/Configure" Provider_ReadResource_FullMethodName = "/tfplugin5.Provider/ReadResource" Provider_PlanResourceChange_FullMethodName = "/tfplugin5.Provider/PlanResourceChange" Provider_ApplyResourceChange_FullMethodName = "/tfplugin5.Provider/ApplyResourceChange" Provider_ImportResourceState_FullMethodName = "/tfplugin5.Provider/ImportResourceState" Provider_MoveResourceState_FullMethodName = "/tfplugin5.Provider/MoveResourceState" Provider_ReadDataSource_FullMethodName = "/tfplugin5.Provider/ReadDataSource" Provider_ValidateEphemeralResourceConfig_FullMethodName = "/tfplugin5.Provider/ValidateEphemeralResourceConfig" Provider_OpenEphemeralResource_FullMethodName = "/tfplugin5.Provider/OpenEphemeralResource" Provider_RenewEphemeralResource_FullMethodName = "/tfplugin5.Provider/RenewEphemeralResource" Provider_CloseEphemeralResource_FullMethodName = "/tfplugin5.Provider/CloseEphemeralResource" Provider_GetFunctions_FullMethodName = "/tfplugin5.Provider/GetFunctions" Provider_CallFunction_FullMethodName = "/tfplugin5.Provider/CallFunction" Provider_Stop_FullMethodName = "/tfplugin5.Provider/Stop" ) // ProviderClient is the client API for Provider service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type ProviderClient interface { // GetMetadata returns upfront information about server capabilities and // supported resource types without requiring the server to instantiate all // schema information, which may be memory intensive. This RPC is optional, // where clients may receive an unimplemented RPC error. Clients should // ignore the error and call the GetSchema RPC as a fallback. GetMetadata(ctx context.Context, in *GetMetadata_Request, opts ...grpc.CallOption) (*GetMetadata_Response, error) // GetSchema returns schema information for the provider, data resources, // and managed resources. GetSchema(ctx context.Context, in *GetProviderSchema_Request, opts ...grpc.CallOption) (*GetProviderSchema_Response, error) // GetResourceIdentitySchemas returns the identity schemas for all managed // resources. GetResourceIdentitySchemas(ctx context.Context, in *GetResourceIdentitySchemas_Request, opts ...grpc.CallOption) (*GetResourceIdentitySchemas_Response, error) PrepareProviderConfig(ctx context.Context, in *PrepareProviderConfig_Request, opts ...grpc.CallOption) (*PrepareProviderConfig_Response, error) ValidateResourceTypeConfig(ctx context.Context, in *ValidateResourceTypeConfig_Request, opts ...grpc.CallOption) (*ValidateResourceTypeConfig_Response, error) ValidateDataSourceConfig(ctx context.Context, in *ValidateDataSourceConfig_Request, opts ...grpc.CallOption) (*ValidateDataSourceConfig_Response, error) UpgradeResourceState(ctx context.Context, in *UpgradeResourceState_Request, opts ...grpc.CallOption) (*UpgradeResourceState_Response, error) // UpgradeResourceIdentityData should return the upgraded resource identity // data for a managed resource type. UpgradeResourceIdentity(ctx context.Context, in *UpgradeResourceIdentity_Request, opts ...grpc.CallOption) (*UpgradeResourceIdentity_Response, error) // ////// One-time initialization, called before other functions below Configure(ctx context.Context, in *Configure_Request, opts ...grpc.CallOption) (*Configure_Response, error) // ////// Managed Resource Lifecycle ReadResource(ctx context.Context, in *ReadResource_Request, opts ...grpc.CallOption) (*ReadResource_Response, error) PlanResourceChange(ctx context.Context, in *PlanResourceChange_Request, opts ...grpc.CallOption) (*PlanResourceChange_Response, error) ApplyResourceChange(ctx context.Context, in *ApplyResourceChange_Request, opts ...grpc.CallOption) (*ApplyResourceChange_Response, error) ImportResourceState(ctx context.Context, in *ImportResourceState_Request, opts ...grpc.CallOption) (*ImportResourceState_Response, error) MoveResourceState(ctx context.Context, in *MoveResourceState_Request, opts ...grpc.CallOption) (*MoveResourceState_Response, error) ReadDataSource(ctx context.Context, in *ReadDataSource_Request, opts ...grpc.CallOption) (*ReadDataSource_Response, error) // ////// Ephemeral Resource Lifecycle ValidateEphemeralResourceConfig(ctx context.Context, in *ValidateEphemeralResourceConfig_Request, opts ...grpc.CallOption) (*ValidateEphemeralResourceConfig_Response, error) OpenEphemeralResource(ctx context.Context, in *OpenEphemeralResource_Request, opts ...grpc.CallOption) (*OpenEphemeralResource_Response, error) RenewEphemeralResource(ctx context.Context, in *RenewEphemeralResource_Request, opts ...grpc.CallOption) (*RenewEphemeralResource_Response, error) CloseEphemeralResource(ctx context.Context, in *CloseEphemeralResource_Request, opts ...grpc.CallOption) (*CloseEphemeralResource_Response, error) // GetFunctions returns the definitions of all functions. GetFunctions(ctx context.Context, in *GetFunctions_Request, opts ...grpc.CallOption) (*GetFunctions_Response, error) // CallFunction runs the provider-defined function logic and returns // the result with any diagnostics. CallFunction(ctx context.Context, in *CallFunction_Request, opts ...grpc.CallOption) (*CallFunction_Response, error) // ////// Graceful Shutdown Stop(ctx context.Context, in *Stop_Request, opts ...grpc.CallOption) (*Stop_Response, error) } type providerClient struct { cc grpc.ClientConnInterface } func NewProviderClient(cc grpc.ClientConnInterface) ProviderClient { return &providerClient{cc} } func (c *providerClient) GetMetadata(ctx context.Context, in *GetMetadata_Request, opts ...grpc.CallOption) (*GetMetadata_Response, error) { out := new(GetMetadata_Response) err := c.cc.Invoke(ctx, Provider_GetMetadata_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) GetSchema(ctx context.Context, in *GetProviderSchema_Request, opts ...grpc.CallOption) (*GetProviderSchema_Response, error) { out := new(GetProviderSchema_Response) err := c.cc.Invoke(ctx, Provider_GetSchema_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) GetResourceIdentitySchemas(ctx context.Context, in *GetResourceIdentitySchemas_Request, opts ...grpc.CallOption) (*GetResourceIdentitySchemas_Response, error) { out := new(GetResourceIdentitySchemas_Response) err := c.cc.Invoke(ctx, Provider_GetResourceIdentitySchemas_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) PrepareProviderConfig(ctx context.Context, in *PrepareProviderConfig_Request, opts ...grpc.CallOption) (*PrepareProviderConfig_Response, error) { out := new(PrepareProviderConfig_Response) err := c.cc.Invoke(ctx, Provider_PrepareProviderConfig_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) ValidateResourceTypeConfig(ctx context.Context, in *ValidateResourceTypeConfig_Request, opts ...grpc.CallOption) (*ValidateResourceTypeConfig_Response, error) { out := new(ValidateResourceTypeConfig_Response) err := c.cc.Invoke(ctx, Provider_ValidateResourceTypeConfig_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) ValidateDataSourceConfig(ctx context.Context, in *ValidateDataSourceConfig_Request, opts ...grpc.CallOption) (*ValidateDataSourceConfig_Response, error) { out := new(ValidateDataSourceConfig_Response) err := c.cc.Invoke(ctx, Provider_ValidateDataSourceConfig_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) UpgradeResourceState(ctx context.Context, in *UpgradeResourceState_Request, opts ...grpc.CallOption) (*UpgradeResourceState_Response, error) { out := new(UpgradeResourceState_Response) err := c.cc.Invoke(ctx, Provider_UpgradeResourceState_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) UpgradeResourceIdentity(ctx context.Context, in *UpgradeResourceIdentity_Request, opts ...grpc.CallOption) (*UpgradeResourceIdentity_Response, error) { out := new(UpgradeResourceIdentity_Response) err := c.cc.Invoke(ctx, Provider_UpgradeResourceIdentity_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) Configure(ctx context.Context, in *Configure_Request, opts ...grpc.CallOption) (*Configure_Response, error) { out := new(Configure_Response) err := c.cc.Invoke(ctx, Provider_Configure_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) ReadResource(ctx context.Context, in *ReadResource_Request, opts ...grpc.CallOption) (*ReadResource_Response, error) { out := new(ReadResource_Response) err := c.cc.Invoke(ctx, Provider_ReadResource_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) PlanResourceChange(ctx context.Context, in *PlanResourceChange_Request, opts ...grpc.CallOption) (*PlanResourceChange_Response, error) { out := new(PlanResourceChange_Response) err := c.cc.Invoke(ctx, Provider_PlanResourceChange_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) ApplyResourceChange(ctx context.Context, in *ApplyResourceChange_Request, opts ...grpc.CallOption) (*ApplyResourceChange_Response, error) { out := new(ApplyResourceChange_Response) err := c.cc.Invoke(ctx, Provider_ApplyResourceChange_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) ImportResourceState(ctx context.Context, in *ImportResourceState_Request, opts ...grpc.CallOption) (*ImportResourceState_Response, error) { out := new(ImportResourceState_Response) err := c.cc.Invoke(ctx, Provider_ImportResourceState_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) MoveResourceState(ctx context.Context, in *MoveResourceState_Request, opts ...grpc.CallOption) (*MoveResourceState_Response, error) { out := new(MoveResourceState_Response) err := c.cc.Invoke(ctx, Provider_MoveResourceState_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) ReadDataSource(ctx context.Context, in *ReadDataSource_Request, opts ...grpc.CallOption) (*ReadDataSource_Response, error) { out := new(ReadDataSource_Response) err := c.cc.Invoke(ctx, Provider_ReadDataSource_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) ValidateEphemeralResourceConfig(ctx context.Context, in *ValidateEphemeralResourceConfig_Request, opts ...grpc.CallOption) (*ValidateEphemeralResourceConfig_Response, error) { out := new(ValidateEphemeralResourceConfig_Response) err := c.cc.Invoke(ctx, Provider_ValidateEphemeralResourceConfig_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) OpenEphemeralResource(ctx context.Context, in *OpenEphemeralResource_Request, opts ...grpc.CallOption) (*OpenEphemeralResource_Response, error) { out := new(OpenEphemeralResource_Response) err := c.cc.Invoke(ctx, Provider_OpenEphemeralResource_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) RenewEphemeralResource(ctx context.Context, in *RenewEphemeralResource_Request, opts ...grpc.CallOption) (*RenewEphemeralResource_Response, error) { out := new(RenewEphemeralResource_Response) err := c.cc.Invoke(ctx, Provider_RenewEphemeralResource_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) CloseEphemeralResource(ctx context.Context, in *CloseEphemeralResource_Request, opts ...grpc.CallOption) (*CloseEphemeralResource_Response, error) { out := new(CloseEphemeralResource_Response) err := c.cc.Invoke(ctx, Provider_CloseEphemeralResource_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) GetFunctions(ctx context.Context, in *GetFunctions_Request, opts ...grpc.CallOption) (*GetFunctions_Response, error) { out := new(GetFunctions_Response) err := c.cc.Invoke(ctx, Provider_GetFunctions_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) CallFunction(ctx context.Context, in *CallFunction_Request, opts ...grpc.CallOption) (*CallFunction_Response, error) { out := new(CallFunction_Response) err := c.cc.Invoke(ctx, Provider_CallFunction_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *providerClient) Stop(ctx context.Context, in *Stop_Request, opts ...grpc.CallOption) (*Stop_Response, error) { out := new(Stop_Response) err := c.cc.Invoke(ctx, Provider_Stop_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } // ProviderServer is the server API for Provider service. // All implementations must embed UnimplementedProviderServer // for forward compatibility type ProviderServer interface { // GetMetadata returns upfront information about server capabilities and // supported resource types without requiring the server to instantiate all // schema information, which may be memory intensive. This RPC is optional, // where clients may receive an unimplemented RPC error. Clients should // ignore the error and call the GetSchema RPC as a fallback. GetMetadata(context.Context, *GetMetadata_Request) (*GetMetadata_Response, error) // GetSchema returns schema information for the provider, data resources, // and managed resources. GetSchema(context.Context, *GetProviderSchema_Request) (*GetProviderSchema_Response, error) // GetResourceIdentitySchemas returns the identity schemas for all managed // resources. GetResourceIdentitySchemas(context.Context, *GetResourceIdentitySchemas_Request) (*GetResourceIdentitySchemas_Response, error) PrepareProviderConfig(context.Context, *PrepareProviderConfig_Request) (*PrepareProviderConfig_Response, error) ValidateResourceTypeConfig(context.Context, *ValidateResourceTypeConfig_Request) (*ValidateResourceTypeConfig_Response, error) ValidateDataSourceConfig(context.Context, *ValidateDataSourceConfig_Request) (*ValidateDataSourceConfig_Response, error) UpgradeResourceState(context.Context, *UpgradeResourceState_Request) (*UpgradeResourceState_Response, error) // UpgradeResourceIdentityData should return the upgraded resource identity // data for a managed resource type. UpgradeResourceIdentity(context.Context, *UpgradeResourceIdentity_Request) (*UpgradeResourceIdentity_Response, error) // ////// One-time initialization, called before other functions below Configure(context.Context, *Configure_Request) (*Configure_Response, error) // ////// Managed Resource Lifecycle ReadResource(context.Context, *ReadResource_Request) (*ReadResource_Response, error) PlanResourceChange(context.Context, *PlanResourceChange_Request) (*PlanResourceChange_Response, error) ApplyResourceChange(context.Context, *ApplyResourceChange_Request) (*ApplyResourceChange_Response, error) ImportResourceState(context.Context, *ImportResourceState_Request) (*ImportResourceState_Response, error) MoveResourceState(context.Context, *MoveResourceState_Request) (*MoveResourceState_Response, error) ReadDataSource(context.Context, *ReadDataSource_Request) (*ReadDataSource_Response, error) // ////// Ephemeral Resource Lifecycle ValidateEphemeralResourceConfig(context.Context, *ValidateEphemeralResourceConfig_Request) (*ValidateEphemeralResourceConfig_Response, error) OpenEphemeralResource(context.Context, *OpenEphemeralResource_Request) (*OpenEphemeralResource_Response, error) RenewEphemeralResource(context.Context, *RenewEphemeralResource_Request) (*RenewEphemeralResource_Response, error) CloseEphemeralResource(context.Context, *CloseEphemeralResource_Request) (*CloseEphemeralResource_Response, error) // GetFunctions returns the definitions of all functions. GetFunctions(context.Context, *GetFunctions_Request) (*GetFunctions_Response, error) // CallFunction runs the provider-defined function logic and returns // the result with any diagnostics. CallFunction(context.Context, *CallFunction_Request) (*CallFunction_Response, error) // ////// Graceful Shutdown Stop(context.Context, *Stop_Request) (*Stop_Response, error) mustEmbedUnimplementedProviderServer() } // UnimplementedProviderServer must be embedded to have forward compatible implementations. type UnimplementedProviderServer struct { } func (UnimplementedProviderServer) GetMetadata(context.Context, *GetMetadata_Request) (*GetMetadata_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method GetMetadata not implemented") } func (UnimplementedProviderServer) GetSchema(context.Context, *GetProviderSchema_Request) (*GetProviderSchema_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method GetSchema not implemented") } func (UnimplementedProviderServer) GetResourceIdentitySchemas(context.Context, *GetResourceIdentitySchemas_Request) (*GetResourceIdentitySchemas_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method GetResourceIdentitySchemas not implemented") } func (UnimplementedProviderServer) PrepareProviderConfig(context.Context, *PrepareProviderConfig_Request) (*PrepareProviderConfig_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method PrepareProviderConfig not implemented") } func (UnimplementedProviderServer) ValidateResourceTypeConfig(context.Context, *ValidateResourceTypeConfig_Request) (*ValidateResourceTypeConfig_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ValidateResourceTypeConfig not implemented") } func (UnimplementedProviderServer) ValidateDataSourceConfig(context.Context, *ValidateDataSourceConfig_Request) (*ValidateDataSourceConfig_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ValidateDataSourceConfig not implemented") } func (UnimplementedProviderServer) UpgradeResourceState(context.Context, *UpgradeResourceState_Request) (*UpgradeResourceState_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method UpgradeResourceState not implemented") } func (UnimplementedProviderServer) UpgradeResourceIdentity(context.Context, *UpgradeResourceIdentity_Request) (*UpgradeResourceIdentity_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method UpgradeResourceIdentity not implemented") } func (UnimplementedProviderServer) Configure(context.Context, *Configure_Request) (*Configure_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method Configure not implemented") } func (UnimplementedProviderServer) ReadResource(context.Context, *ReadResource_Request) (*ReadResource_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ReadResource not implemented") } func (UnimplementedProviderServer) PlanResourceChange(context.Context, *PlanResourceChange_Request) (*PlanResourceChange_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method PlanResourceChange not implemented") } func (UnimplementedProviderServer) ApplyResourceChange(context.Context, *ApplyResourceChange_Request) (*ApplyResourceChange_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ApplyResourceChange not implemented") } func (UnimplementedProviderServer) ImportResourceState(context.Context, *ImportResourceState_Request) (*ImportResourceState_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ImportResourceState not implemented") } func (UnimplementedProviderServer) MoveResourceState(context.Context, *MoveResourceState_Request) (*MoveResourceState_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method MoveResourceState not implemented") } func (UnimplementedProviderServer) ReadDataSource(context.Context, *ReadDataSource_Request) (*ReadDataSource_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ReadDataSource not implemented") } func (UnimplementedProviderServer) ValidateEphemeralResourceConfig(context.Context, *ValidateEphemeralResourceConfig_Request) (*ValidateEphemeralResourceConfig_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ValidateEphemeralResourceConfig not implemented") } func (UnimplementedProviderServer) OpenEphemeralResource(context.Context, *OpenEphemeralResource_Request) (*OpenEphemeralResource_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method OpenEphemeralResource not implemented") } func (UnimplementedProviderServer) RenewEphemeralResource(context.Context, *RenewEphemeralResource_Request) (*RenewEphemeralResource_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method RenewEphemeralResource not implemented") } func (UnimplementedProviderServer) CloseEphemeralResource(context.Context, *CloseEphemeralResource_Request) (*CloseEphemeralResource_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method CloseEphemeralResource not implemented") } func (UnimplementedProviderServer) GetFunctions(context.Context, *GetFunctions_Request) (*GetFunctions_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method GetFunctions not implemented") } func (UnimplementedProviderServer) CallFunction(context.Context, *CallFunction_Request) (*CallFunction_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method CallFunction not implemented") } func (UnimplementedProviderServer) Stop(context.Context, *Stop_Request) (*Stop_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method Stop not implemented") } func (UnimplementedProviderServer) mustEmbedUnimplementedProviderServer() {} // UnsafeProviderServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ProviderServer will // result in compilation errors. type UnsafeProviderServer interface { mustEmbedUnimplementedProviderServer() } func RegisterProviderServer(s grpc.ServiceRegistrar, srv ProviderServer) { s.RegisterService(&Provider_ServiceDesc, srv) } func _Provider_GetMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetMetadata_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).GetMetadata(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_GetMetadata_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).GetMetadata(ctx, req.(*GetMetadata_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_GetSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetProviderSchema_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).GetSchema(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_GetSchema_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).GetSchema(ctx, req.(*GetProviderSchema_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_GetResourceIdentitySchemas_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetResourceIdentitySchemas_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).GetResourceIdentitySchemas(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_GetResourceIdentitySchemas_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).GetResourceIdentitySchemas(ctx, req.(*GetResourceIdentitySchemas_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_PrepareProviderConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(PrepareProviderConfig_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).PrepareProviderConfig(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_PrepareProviderConfig_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).PrepareProviderConfig(ctx, req.(*PrepareProviderConfig_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_ValidateResourceTypeConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ValidateResourceTypeConfig_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).ValidateResourceTypeConfig(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_ValidateResourceTypeConfig_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).ValidateResourceTypeConfig(ctx, req.(*ValidateResourceTypeConfig_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_ValidateDataSourceConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ValidateDataSourceConfig_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).ValidateDataSourceConfig(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_ValidateDataSourceConfig_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).ValidateDataSourceConfig(ctx, req.(*ValidateDataSourceConfig_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_UpgradeResourceState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpgradeResourceState_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).UpgradeResourceState(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_UpgradeResourceState_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).UpgradeResourceState(ctx, req.(*UpgradeResourceState_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_UpgradeResourceIdentity_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpgradeResourceIdentity_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).UpgradeResourceIdentity(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_UpgradeResourceIdentity_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).UpgradeResourceIdentity(ctx, req.(*UpgradeResourceIdentity_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_Configure_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(Configure_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).Configure(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_Configure_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).Configure(ctx, req.(*Configure_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_ReadResource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ReadResource_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).ReadResource(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_ReadResource_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).ReadResource(ctx, req.(*ReadResource_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_PlanResourceChange_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(PlanResourceChange_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).PlanResourceChange(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_PlanResourceChange_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).PlanResourceChange(ctx, req.(*PlanResourceChange_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_ApplyResourceChange_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ApplyResourceChange_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).ApplyResourceChange(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_ApplyResourceChange_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).ApplyResourceChange(ctx, req.(*ApplyResourceChange_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_ImportResourceState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ImportResourceState_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).ImportResourceState(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_ImportResourceState_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).ImportResourceState(ctx, req.(*ImportResourceState_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_MoveResourceState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MoveResourceState_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).MoveResourceState(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_MoveResourceState_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).MoveResourceState(ctx, req.(*MoveResourceState_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_ReadDataSource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ReadDataSource_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).ReadDataSource(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_ReadDataSource_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).ReadDataSource(ctx, req.(*ReadDataSource_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_ValidateEphemeralResourceConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ValidateEphemeralResourceConfig_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).ValidateEphemeralResourceConfig(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_ValidateEphemeralResourceConfig_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).ValidateEphemeralResourceConfig(ctx, req.(*ValidateEphemeralResourceConfig_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_OpenEphemeralResource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(OpenEphemeralResource_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).OpenEphemeralResource(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_OpenEphemeralResource_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).OpenEphemeralResource(ctx, req.(*OpenEphemeralResource_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_RenewEphemeralResource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(RenewEphemeralResource_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).RenewEphemeralResource(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_RenewEphemeralResource_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).RenewEphemeralResource(ctx, req.(*RenewEphemeralResource_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_CloseEphemeralResource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CloseEphemeralResource_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).CloseEphemeralResource(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_CloseEphemeralResource_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).CloseEphemeralResource(ctx, req.(*CloseEphemeralResource_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_GetFunctions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetFunctions_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).GetFunctions(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_GetFunctions_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).GetFunctions(ctx, req.(*GetFunctions_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_CallFunction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CallFunction_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).CallFunction(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_CallFunction_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).CallFunction(ctx, req.(*CallFunction_Request)) } return interceptor(ctx, in, info, handler) } func _Provider_Stop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(Stop_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProviderServer).Stop(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provider_Stop_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProviderServer).Stop(ctx, req.(*Stop_Request)) } return interceptor(ctx, in, info, handler) } // Provider_ServiceDesc is the grpc.ServiceDesc for Provider service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var Provider_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tfplugin5.Provider", HandlerType: (*ProviderServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetMetadata", Handler: _Provider_GetMetadata_Handler, }, { MethodName: "GetSchema", Handler: _Provider_GetSchema_Handler, }, { MethodName: "GetResourceIdentitySchemas", Handler: _Provider_GetResourceIdentitySchemas_Handler, }, { MethodName: "PrepareProviderConfig", Handler: _Provider_PrepareProviderConfig_Handler, }, { MethodName: "ValidateResourceTypeConfig", Handler: _Provider_ValidateResourceTypeConfig_Handler, }, { MethodName: "ValidateDataSourceConfig", Handler: _Provider_ValidateDataSourceConfig_Handler, }, { MethodName: "UpgradeResourceState", Handler: _Provider_UpgradeResourceState_Handler, }, { MethodName: "UpgradeResourceIdentity", Handler: _Provider_UpgradeResourceIdentity_Handler, }, { MethodName: "Configure", Handler: _Provider_Configure_Handler, }, { MethodName: "ReadResource", Handler: _Provider_ReadResource_Handler, }, { MethodName: "PlanResourceChange", Handler: _Provider_PlanResourceChange_Handler, }, { MethodName: "ApplyResourceChange", Handler: _Provider_ApplyResourceChange_Handler, }, { MethodName: "ImportResourceState", Handler: _Provider_ImportResourceState_Handler, }, { MethodName: "MoveResourceState", Handler: _Provider_MoveResourceState_Handler, }, { MethodName: "ReadDataSource", Handler: _Provider_ReadDataSource_Handler, }, { MethodName: "ValidateEphemeralResourceConfig", Handler: _Provider_ValidateEphemeralResourceConfig_Handler, }, { MethodName: "OpenEphemeralResource", Handler: _Provider_OpenEphemeralResource_Handler, }, { MethodName: "RenewEphemeralResource", Handler: _Provider_RenewEphemeralResource_Handler, }, { MethodName: "CloseEphemeralResource", Handler: _Provider_CloseEphemeralResource_Handler, }, { MethodName: "GetFunctions", Handler: _Provider_GetFunctions_Handler, }, { MethodName: "CallFunction", Handler: _Provider_CallFunction_Handler, }, { MethodName: "Stop", Handler: _Provider_Stop_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "tfplugin5.proto", } const ( Provisioner_GetSchema_FullMethodName = "/tfplugin5.Provisioner/GetSchema" Provisioner_ValidateProvisionerConfig_FullMethodName = "/tfplugin5.Provisioner/ValidateProvisionerConfig" Provisioner_ProvisionResource_FullMethodName = "/tfplugin5.Provisioner/ProvisionResource" Provisioner_Stop_FullMethodName = "/tfplugin5.Provisioner/Stop" ) // ProvisionerClient is the client API for Provisioner service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type ProvisionerClient interface { GetSchema(ctx context.Context, in *GetProvisionerSchema_Request, opts ...grpc.CallOption) (*GetProvisionerSchema_Response, error) ValidateProvisionerConfig(ctx context.Context, in *ValidateProvisionerConfig_Request, opts ...grpc.CallOption) (*ValidateProvisionerConfig_Response, error) ProvisionResource(ctx context.Context, in *ProvisionResource_Request, opts ...grpc.CallOption) (Provisioner_ProvisionResourceClient, error) Stop(ctx context.Context, in *Stop_Request, opts ...grpc.CallOption) (*Stop_Response, error) } type provisionerClient struct { cc grpc.ClientConnInterface } func NewProvisionerClient(cc grpc.ClientConnInterface) ProvisionerClient { return &provisionerClient{cc} } func (c *provisionerClient) GetSchema(ctx context.Context, in *GetProvisionerSchema_Request, opts ...grpc.CallOption) (*GetProvisionerSchema_Response, error) { out := new(GetProvisionerSchema_Response) err := c.cc.Invoke(ctx, Provisioner_GetSchema_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *provisionerClient) ValidateProvisionerConfig(ctx context.Context, in *ValidateProvisionerConfig_Request, opts ...grpc.CallOption) (*ValidateProvisionerConfig_Response, error) { out := new(ValidateProvisionerConfig_Response) err := c.cc.Invoke(ctx, Provisioner_ValidateProvisionerConfig_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *provisionerClient) ProvisionResource(ctx context.Context, in *ProvisionResource_Request, opts ...grpc.CallOption) (Provisioner_ProvisionResourceClient, error) { stream, err := c.cc.NewStream(ctx, &Provisioner_ServiceDesc.Streams[0], Provisioner_ProvisionResource_FullMethodName, opts...) if err != nil { return nil, err } x := &provisionerProvisionResourceClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } if err := x.ClientStream.CloseSend(); err != nil { return nil, err } return x, nil } type Provisioner_ProvisionResourceClient interface { Recv() (*ProvisionResource_Response, error) grpc.ClientStream } type provisionerProvisionResourceClient struct { grpc.ClientStream } func (x *provisionerProvisionResourceClient) Recv() (*ProvisionResource_Response, error) { m := new(ProvisionResource_Response) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *provisionerClient) Stop(ctx context.Context, in *Stop_Request, opts ...grpc.CallOption) (*Stop_Response, error) { out := new(Stop_Response) err := c.cc.Invoke(ctx, Provisioner_Stop_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } // ProvisionerServer is the server API for Provisioner service. // All implementations must embed UnimplementedProvisionerServer // for forward compatibility type ProvisionerServer interface { GetSchema(context.Context, *GetProvisionerSchema_Request) (*GetProvisionerSchema_Response, error) ValidateProvisionerConfig(context.Context, *ValidateProvisionerConfig_Request) (*ValidateProvisionerConfig_Response, error) ProvisionResource(*ProvisionResource_Request, Provisioner_ProvisionResourceServer) error Stop(context.Context, *Stop_Request) (*Stop_Response, error) mustEmbedUnimplementedProvisionerServer() } // UnimplementedProvisionerServer must be embedded to have forward compatible implementations. type UnimplementedProvisionerServer struct { } func (UnimplementedProvisionerServer) GetSchema(context.Context, *GetProvisionerSchema_Request) (*GetProvisionerSchema_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method GetSchema not implemented") } func (UnimplementedProvisionerServer) ValidateProvisionerConfig(context.Context, *ValidateProvisionerConfig_Request) (*ValidateProvisionerConfig_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ValidateProvisionerConfig not implemented") } func (UnimplementedProvisionerServer) ProvisionResource(*ProvisionResource_Request, Provisioner_ProvisionResourceServer) error { return status.Errorf(codes.Unimplemented, "method ProvisionResource not implemented") } func (UnimplementedProvisionerServer) Stop(context.Context, *Stop_Request) (*Stop_Response, error) { return nil, status.Errorf(codes.Unimplemented, "method Stop not implemented") } func (UnimplementedProvisionerServer) mustEmbedUnimplementedProvisionerServer() {} // UnsafeProvisionerServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ProvisionerServer will // result in compilation errors. type UnsafeProvisionerServer interface { mustEmbedUnimplementedProvisionerServer() } func RegisterProvisionerServer(s grpc.ServiceRegistrar, srv ProvisionerServer) { s.RegisterService(&Provisioner_ServiceDesc, srv) } func _Provisioner_GetSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetProvisionerSchema_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProvisionerServer).GetSchema(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provisioner_GetSchema_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProvisionerServer).GetSchema(ctx, req.(*GetProvisionerSchema_Request)) } return interceptor(ctx, in, info, handler) } func _Provisioner_ValidateProvisionerConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ValidateProvisionerConfig_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProvisionerServer).ValidateProvisionerConfig(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provisioner_ValidateProvisionerConfig_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProvisionerServer).ValidateProvisionerConfig(ctx, req.(*ValidateProvisionerConfig_Request)) } return interceptor(ctx, in, info, handler) } func _Provisioner_ProvisionResource_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(ProvisionResource_Request) if err := stream.RecvMsg(m); err != nil { return err } return srv.(ProvisionerServer).ProvisionResource(m, &provisionerProvisionResourceServer{stream}) } type Provisioner_ProvisionResourceServer interface { Send(*ProvisionResource_Response) error grpc.ServerStream } type provisionerProvisionResourceServer struct { grpc.ServerStream } func (x *provisionerProvisionResourceServer) Send(m *ProvisionResource_Response) error { return x.ServerStream.SendMsg(m) } func _Provisioner_Stop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(Stop_Request) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProvisionerServer).Stop(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Provisioner_Stop_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProvisionerServer).Stop(ctx, req.(*Stop_Request)) } return interceptor(ctx, in, info, handler) } // Provisioner_ServiceDesc is the grpc.ServiceDesc for Provisioner service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var Provisioner_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tfplugin5.Provisioner", HandlerType: (*ProvisionerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetSchema", Handler: _Provisioner_GetSchema_Handler, }, { MethodName: "ValidateProvisionerConfig", Handler: _Provisioner_ValidateProvisionerConfig_Handler, }, { MethodName: "Stop", Handler: _Provisioner_Stop_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ProvisionResource", Handler: _Provisioner_ProvisionResource_Handler, ServerStreams: true, }, }, Metadata: "tfplugin5.proto", }