@ -21,8 +21,8 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1. 3.0
// - protoc v 3.15.6
// - protoc-gen-go-grpc v1. 5.1
// - protoc v 5.29.3
// source: tfplugin6.proto
package tfplugin6
@ -36,8 +36,8 @@ import (
// 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 . SupportPackageIsVersion 7
// Requires gRPC-Go v1. 64 .0 or later.
const _ = grpc . SupportPackageIsVersion 9
const (
Provider_GetMetadata_FullMethodName = "/tfplugin6.Provider/GetMetadata"
@ -117,7 +117,7 @@ type ProviderClient interface {
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 )
// ///// List
ListResource ( ctx context . Context , in * ListResource_Request , opts ... grpc . CallOption ) ( Provider_ListResourceClient , error )
ListResource ( ctx context . Context , in * ListResource_Request , opts ... grpc . CallOption ) ( grpc. ServerStreamingClient [ ListResource_Event ] , error )
ValidateListResourceConfig ( ctx context . Context , in * ValidateListResourceConfig_Request , opts ... grpc . CallOption ) ( * ValidateListResourceConfig_Response , error )
// GetFunctions returns the definitions of all functions.
GetFunctions ( ctx context . Context , in * GetFunctions_Request , opts ... grpc . CallOption ) ( * GetFunctions_Response , error )
@ -128,9 +128,9 @@ type ProviderClient interface {
// ConfigureStateStore configures the state store, such as S3 connection in the context of already configured provider
ConfigureStateStore ( ctx context . Context , in * ConfigureStateStore_Request , opts ... grpc . CallOption ) ( * ConfigureStateStore_Response , error )
// ReadStateBytes streams byte chunks of a given state file from a state store
ReadStateBytes ( ctx context . Context , in * ReadStateBytes_Request , opts ... grpc . CallOption ) ( Provider_ReadStateBytesClient , error )
ReadStateBytes ( ctx context . Context , in * ReadStateBytes_Request , opts ... grpc . CallOption ) ( grpc. ServerStreamingClient [ ReadStateBytes_Response ] , error )
// WriteStateBytes streams byte chunks of a given state file into a state store
WriteStateBytes ( ctx context . Context , opts ... grpc . CallOption ) ( Provider_WriteStateBytesClient , error )
WriteStateBytes ( ctx context . Context , opts ... grpc . CallOption ) ( grpc. ClientStreamingClient [ WriteStateBytes_RequestChunk , WriteStateBytes_Response ] , error )
// LockState locks a given state (i.e. CE workspace)
LockState ( ctx context . Context , in * LockState_Request , opts ... grpc . CallOption ) ( * LockState_Response , error )
// UnlockState unlocks a given state (i.e. CE workspace)
@ -141,7 +141,7 @@ type ProviderClient interface {
DeleteState ( ctx context . Context , in * DeleteState_Request , opts ... grpc . CallOption ) ( * DeleteState_Response , error )
// ////// Actions
PlanAction ( ctx context . Context , in * PlanAction_Request , opts ... grpc . CallOption ) ( * PlanAction_Response , error )
InvokeAction ( ctx context . Context , in * InvokeAction_Request , opts ... grpc . CallOption ) ( Provider_InvokeActionClient , error )
InvokeAction ( ctx context . Context , in * InvokeAction_Request , opts ... grpc . CallOption ) ( grpc. ServerStreamingClient [ InvokeAction_Event ] , error )
ValidateActionConfig ( ctx context . Context , in * ValidateActionConfig_Request , opts ... grpc . CallOption ) ( * ValidateActionConfig_Response , error )
// ////// Graceful Shutdown
StopProvider ( ctx context . Context , in * StopProvider_Request , opts ... grpc . CallOption ) ( * StopProvider_Response , error )
@ -156,8 +156,9 @@ func NewProviderClient(cc grpc.ClientConnInterface) ProviderClient {
}
func ( c * providerClient ) GetMetadata ( ctx context . Context , in * GetMetadata_Request , opts ... grpc . CallOption ) ( * GetMetadata_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( GetMetadata_Response )
err := c . cc . Invoke ( ctx , Provider_GetMetadata_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_GetMetadata_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -165,8 +166,9 @@ func (c *providerClient) GetMetadata(ctx context.Context, in *GetMetadata_Reques
}
func ( c * providerClient ) GetProviderSchema ( ctx context . Context , in * GetProviderSchema_Request , opts ... grpc . CallOption ) ( * GetProviderSchema_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( GetProviderSchema_Response )
err := c . cc . Invoke ( ctx , Provider_GetProviderSchema_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_GetProviderSchema_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -174,8 +176,9 @@ func (c *providerClient) GetProviderSchema(ctx context.Context, in *GetProviderS
}
func ( c * providerClient ) ValidateProviderConfig ( ctx context . Context , in * ValidateProviderConfig_Request , opts ... grpc . CallOption ) ( * ValidateProviderConfig_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ValidateProviderConfig_Response )
err := c . cc . Invoke ( ctx , Provider_ValidateProviderConfig_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ValidateProviderConfig_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -183,8 +186,9 @@ func (c *providerClient) ValidateProviderConfig(ctx context.Context, in *Validat
}
func ( c * providerClient ) ValidateResourceConfig ( ctx context . Context , in * ValidateResourceConfig_Request , opts ... grpc . CallOption ) ( * ValidateResourceConfig_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ValidateResourceConfig_Response )
err := c . cc . Invoke ( ctx , Provider_ValidateResourceConfig_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ValidateResourceConfig_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -192,8 +196,9 @@ func (c *providerClient) ValidateResourceConfig(ctx context.Context, in *Validat
}
func ( c * providerClient ) ValidateDataResourceConfig ( ctx context . Context , in * ValidateDataResourceConfig_Request , opts ... grpc . CallOption ) ( * ValidateDataResourceConfig_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ValidateDataResourceConfig_Response )
err := c . cc . Invoke ( ctx , Provider_ValidateDataResourceConfig_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ValidateDataResourceConfig_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -201,8 +206,9 @@ func (c *providerClient) ValidateDataResourceConfig(ctx context.Context, in *Val
}
func ( c * providerClient ) UpgradeResourceState ( ctx context . Context , in * UpgradeResourceState_Request , opts ... grpc . CallOption ) ( * UpgradeResourceState_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( UpgradeResourceState_Response )
err := c . cc . Invoke ( ctx , Provider_UpgradeResourceState_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_UpgradeResourceState_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -210,8 +216,9 @@ func (c *providerClient) UpgradeResourceState(ctx context.Context, in *UpgradeRe
}
func ( c * providerClient ) GetResourceIdentitySchemas ( ctx context . Context , in * GetResourceIdentitySchemas_Request , opts ... grpc . CallOption ) ( * GetResourceIdentitySchemas_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( GetResourceIdentitySchemas_Response )
err := c . cc . Invoke ( ctx , Provider_GetResourceIdentitySchemas_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_GetResourceIdentitySchemas_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -219,8 +226,9 @@ func (c *providerClient) GetResourceIdentitySchemas(ctx context.Context, in *Get
}
func ( c * providerClient ) UpgradeResourceIdentity ( ctx context . Context , in * UpgradeResourceIdentity_Request , opts ... grpc . CallOption ) ( * UpgradeResourceIdentity_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( UpgradeResourceIdentity_Response )
err := c . cc . Invoke ( ctx , Provider_UpgradeResourceIdentity_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_UpgradeResourceIdentity_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -228,8 +236,9 @@ func (c *providerClient) UpgradeResourceIdentity(ctx context.Context, in *Upgrad
}
func ( c * providerClient ) ConfigureProvider ( ctx context . Context , in * ConfigureProvider_Request , opts ... grpc . CallOption ) ( * ConfigureProvider_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ConfigureProvider_Response )
err := c . cc . Invoke ( ctx , Provider_ConfigureProvider_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ConfigureProvider_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -237,8 +246,9 @@ func (c *providerClient) ConfigureProvider(ctx context.Context, in *ConfigurePro
}
func ( c * providerClient ) ReadResource ( ctx context . Context , in * ReadResource_Request , opts ... grpc . CallOption ) ( * ReadResource_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ReadResource_Response )
err := c . cc . Invoke ( ctx , Provider_ReadResource_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ReadResource_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -246,8 +256,9 @@ func (c *providerClient) ReadResource(ctx context.Context, in *ReadResource_Requ
}
func ( c * providerClient ) PlanResourceChange ( ctx context . Context , in * PlanResourceChange_Request , opts ... grpc . CallOption ) ( * PlanResourceChange_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( PlanResourceChange_Response )
err := c . cc . Invoke ( ctx , Provider_PlanResourceChange_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_PlanResourceChange_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -255,8 +266,9 @@ func (c *providerClient) PlanResourceChange(ctx context.Context, in *PlanResourc
}
func ( c * providerClient ) ApplyResourceChange ( ctx context . Context , in * ApplyResourceChange_Request , opts ... grpc . CallOption ) ( * ApplyResourceChange_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ApplyResourceChange_Response )
err := c . cc . Invoke ( ctx , Provider_ApplyResourceChange_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ApplyResourceChange_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -264,8 +276,9 @@ func (c *providerClient) ApplyResourceChange(ctx context.Context, in *ApplyResou
}
func ( c * providerClient ) ImportResourceState ( ctx context . Context , in * ImportResourceState_Request , opts ... grpc . CallOption ) ( * ImportResourceState_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ImportResourceState_Response )
err := c . cc . Invoke ( ctx , Provider_ImportResourceState_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ImportResourceState_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -273,8 +286,9 @@ func (c *providerClient) ImportResourceState(ctx context.Context, in *ImportReso
}
func ( c * providerClient ) MoveResourceState ( ctx context . Context , in * MoveResourceState_Request , opts ... grpc . CallOption ) ( * MoveResourceState_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( MoveResourceState_Response )
err := c . cc . Invoke ( ctx , Provider_MoveResourceState_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_MoveResourceState_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -282,8 +296,9 @@ func (c *providerClient) MoveResourceState(ctx context.Context, in *MoveResource
}
func ( c * providerClient ) ReadDataSource ( ctx context . Context , in * ReadDataSource_Request , opts ... grpc . CallOption ) ( * ReadDataSource_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ReadDataSource_Response )
err := c . cc . Invoke ( ctx , Provider_ReadDataSource_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ReadDataSource_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -291,8 +306,9 @@ func (c *providerClient) ReadDataSource(ctx context.Context, in *ReadDataSource_
}
func ( c * providerClient ) GenerateResourceConfig ( ctx context . Context , in * GenerateResourceConfig_Request , opts ... grpc . CallOption ) ( * GenerateResourceConfig_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( GenerateResourceConfig_Response )
err := c . cc . Invoke ( ctx , Provider_GenerateResourceConfig_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_GenerateResourceConfig_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -300,8 +316,9 @@ func (c *providerClient) GenerateResourceConfig(ctx context.Context, in *Generat
}
func ( c * providerClient ) ValidateEphemeralResourceConfig ( ctx context . Context , in * ValidateEphemeralResourceConfig_Request , opts ... grpc . CallOption ) ( * ValidateEphemeralResourceConfig_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ValidateEphemeralResourceConfig_Response )
err := c . cc . Invoke ( ctx , Provider_ValidateEphemeralResourceConfig_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ValidateEphemeralResourceConfig_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -309,8 +326,9 @@ func (c *providerClient) ValidateEphemeralResourceConfig(ctx context.Context, in
}
func ( c * providerClient ) OpenEphemeralResource ( ctx context . Context , in * OpenEphemeralResource_Request , opts ... grpc . CallOption ) ( * OpenEphemeralResource_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( OpenEphemeralResource_Response )
err := c . cc . Invoke ( ctx , Provider_OpenEphemeralResource_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_OpenEphemeralResource_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -318,8 +336,9 @@ func (c *providerClient) OpenEphemeralResource(ctx context.Context, in *OpenEphe
}
func ( c * providerClient ) RenewEphemeralResource ( ctx context . Context , in * RenewEphemeralResource_Request , opts ... grpc . CallOption ) ( * RenewEphemeralResource_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( RenewEphemeralResource_Response )
err := c . cc . Invoke ( ctx , Provider_RenewEphemeralResource_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_RenewEphemeralResource_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -327,20 +346,22 @@ func (c *providerClient) RenewEphemeralResource(ctx context.Context, in *RenewEp
}
func ( c * providerClient ) CloseEphemeralResource ( ctx context . Context , in * CloseEphemeralResource_Request , opts ... grpc . CallOption ) ( * CloseEphemeralResource_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( CloseEphemeralResource_Response )
err := c . cc . Invoke ( ctx , Provider_CloseEphemeralResource_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_CloseEphemeralResource_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
return out , nil
}
func ( c * providerClient ) ListResource ( ctx context . Context , in * ListResource_Request , opts ... grpc . CallOption ) ( Provider_ListResourceClient , error ) {
stream , err := c . cc . NewStream ( ctx , & Provider_ServiceDesc . Streams [ 0 ] , Provider_ListResource_FullMethodName , opts ... )
func ( c * providerClient ) ListResource ( ctx context . Context , in * ListResource_Request , opts ... grpc . CallOption ) ( grpc . ServerStreamingClient [ ListResource_Event ] , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
stream , err := c . cc . NewStream ( ctx , & Provider_ServiceDesc . Streams [ 0 ] , Provider_ListResource_FullMethodName , cOpts ... )
if err != nil {
return nil , err
}
x := & providerListResourceClient{ stream }
x := & grpc. GenericClientStream [ ListResource_Request , ListResource_Event ] { ClientStream : stream }
if err := x . ClientStream . SendMsg ( in ) ; err != nil {
return nil , err
}
@ -350,26 +371,13 @@ func (c *providerClient) ListResource(ctx context.Context, in *ListResource_Requ
return x , nil
}
type Provider_ListResourceClient interface {
Recv ( ) ( * ListResource_Event , error )
grpc . ClientStream
}
type providerListResourceClient struct {
grpc . ClientStream
}
func ( x * providerListResourceClient ) Recv ( ) ( * ListResource_Event , error ) {
m := new ( ListResource_Event )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Provider_ListResourceClient = grpc . ServerStreamingClient [ ListResource_Event ]
func ( c * providerClient ) ValidateListResourceConfig ( ctx context . Context , in * ValidateListResourceConfig_Request , opts ... grpc . CallOption ) ( * ValidateListResourceConfig_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ValidateListResourceConfig_Response )
err := c . cc . Invoke ( ctx , Provider_ValidateListResourceConfig_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ValidateListResourceConfig_FullMethodName , in , out , cOpts ... )
if err != nil {
return nil , err
}
@ -377,8 +385,9 @@ func (c *providerClient) ValidateListResourceConfig(ctx context.Context, in *Val
}
func ( c * providerClient ) GetFunctions ( ctx context . Context , in * GetFunctions_Request , opts ... grpc . CallOption ) ( * GetFunctions_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( GetFunctions_Response )
err := c . cc . Invoke ( ctx , Provider_GetFunctions_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_GetFunctions_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -386,8 +395,9 @@ func (c *providerClient) GetFunctions(ctx context.Context, in *GetFunctions_Requ
}
func ( c * providerClient ) CallFunction ( ctx context . Context , in * CallFunction_Request , opts ... grpc . CallOption ) ( * CallFunction_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( CallFunction_Response )
err := c . cc . Invoke ( ctx , Provider_CallFunction_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_CallFunction_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -395,8 +405,9 @@ func (c *providerClient) CallFunction(ctx context.Context, in *CallFunction_Requ
}
func ( c * providerClient ) ValidateStateStoreConfig ( ctx context . Context , in * ValidateStateStore_Request , opts ... grpc . CallOption ) ( * ValidateStateStore_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ValidateStateStore_Response )
err := c . cc . Invoke ( ctx , Provider_ValidateStateStoreConfig_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ValidateStateStoreConfig_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -404,20 +415,22 @@ func (c *providerClient) ValidateStateStoreConfig(ctx context.Context, in *Valid
}
func ( c * providerClient ) ConfigureStateStore ( ctx context . Context , in * ConfigureStateStore_Request , opts ... grpc . CallOption ) ( * ConfigureStateStore_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ConfigureStateStore_Response )
err := c . cc . Invoke ( ctx , Provider_ConfigureStateStore_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ConfigureStateStore_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
return out , nil
}
func ( c * providerClient ) ReadStateBytes ( ctx context . Context , in * ReadStateBytes_Request , opts ... grpc . CallOption ) ( Provider_ReadStateBytesClient , error ) {
stream , err := c . cc . NewStream ( ctx , & Provider_ServiceDesc . Streams [ 1 ] , Provider_ReadStateBytes_FullMethodName , opts ... )
func ( c * providerClient ) ReadStateBytes ( ctx context . Context , in * ReadStateBytes_Request , opts ... grpc . CallOption ) ( grpc . ServerStreamingClient [ ReadStateBytes_Response ] , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
stream , err := c . cc . NewStream ( ctx , & Provider_ServiceDesc . Streams [ 1 ] , Provider_ReadStateBytes_FullMethodName , cOpts ... )
if err != nil {
return nil , err
}
x := & providerReadStateBytesClient{ stream }
x := & grpc. GenericClientStream [ ReadStateBytes_Request , ReadStateBytes_Response ] { ClientStream : stream }
if err := x . ClientStream . SendMsg ( in ) ; err != nil {
return nil , err
}
@ -427,60 +440,26 @@ func (c *providerClient) ReadStateBytes(ctx context.Context, in *ReadStateBytes_
return x , nil
}
type Provider_ReadStateBytesClient interface {
Recv ( ) ( * ReadStateBytes_Response , error )
grpc . ClientStream
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Provider_ReadStateBytesClient = grpc . ServerStreamingClient [ ReadStateBytes_Response ]
type providerReadStateBytesClient struct {
grpc . ClientStream
}
func ( x * providerReadStateBytesClient ) Recv ( ) ( * ReadStateBytes_Response , error ) {
m := new ( ReadStateBytes_Response )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
func ( c * providerClient ) WriteStateBytes ( ctx context . Context , opts ... grpc . CallOption ) ( Provider_WriteStateBytesClient , error ) {
stream , err := c . cc . NewStream ( ctx , & Provider_ServiceDesc . Streams [ 2 ] , Provider_WriteStateBytes_FullMethodName , opts ... )
func ( c * providerClient ) WriteStateBytes ( ctx context . Context , opts ... grpc . CallOption ) ( grpc . ClientStreamingClient [ WriteStateBytes_RequestChunk , WriteStateBytes_Response ] , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
stream , err := c . cc . NewStream ( ctx , & Provider_ServiceDesc . Streams [ 2 ] , Provider_WriteStateBytes_FullMethodName , cOpts ... )
if err != nil {
return nil , err
}
x := & providerWriteStateBytesClient{ stream }
x := & grpc . GenericClientStream [ WriteStateBytes_RequestChunk , WriteStateBytes_Response ] { ClientStream : stream }
return x , nil
}
type Provider_WriteStateBytesClient interface {
Send ( * WriteStateBytes_RequestChunk ) error
CloseAndRecv ( ) ( * WriteStateBytes_Response , error )
grpc . ClientStream
}
type providerWriteStateBytesClient struct {
grpc . ClientStream
}
func ( x * providerWriteStateBytesClient ) Send ( m * WriteStateBytes_RequestChunk ) error {
return x . ClientStream . SendMsg ( m )
}
func ( x * providerWriteStateBytesClient ) CloseAndRecv ( ) ( * WriteStateBytes_Response , error ) {
if err := x . ClientStream . CloseSend ( ) ; err != nil {
return nil , err
}
m := new ( WriteStateBytes_Response )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Provider_WriteStateBytesClient = grpc . ClientStreamingClient [ WriteStateBytes_RequestChunk , WriteStateBytes_Response ]
func ( c * providerClient ) LockState ( ctx context . Context , in * LockState_Request , opts ... grpc . CallOption ) ( * LockState_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( LockState_Response )
err := c . cc . Invoke ( ctx , Provider_LockState_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_LockState_FullMethodName , in , out , cOpts ... )
if err != nil {
return nil , err
}
@ -488,8 +467,9 @@ func (c *providerClient) LockState(ctx context.Context, in *LockState_Request, o
}
func ( c * providerClient ) UnlockState ( ctx context . Context , in * UnlockState_Request , opts ... grpc . CallOption ) ( * UnlockState_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( UnlockState_Response )
err := c . cc . Invoke ( ctx , Provider_UnlockState_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_UnlockState_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -497,8 +477,9 @@ func (c *providerClient) UnlockState(ctx context.Context, in *UnlockState_Reques
}
func ( c * providerClient ) GetStates ( ctx context . Context , in * GetStates_Request , opts ... grpc . CallOption ) ( * GetStates_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( GetStates_Response )
err := c . cc . Invoke ( ctx , Provider_GetStates_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_GetStates_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -506,8 +487,9 @@ func (c *providerClient) GetStates(ctx context.Context, in *GetStates_Request, o
}
func ( c * providerClient ) DeleteState ( ctx context . Context , in * DeleteState_Request , opts ... grpc . CallOption ) ( * DeleteState_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( DeleteState_Response )
err := c . cc . Invoke ( ctx , Provider_DeleteState_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_DeleteState_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -515,20 +497,22 @@ func (c *providerClient) DeleteState(ctx context.Context, in *DeleteState_Reques
}
func ( c * providerClient ) PlanAction ( ctx context . Context , in * PlanAction_Request , opts ... grpc . CallOption ) ( * PlanAction_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( PlanAction_Response )
err := c . cc . Invoke ( ctx , Provider_PlanAction_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_PlanAction_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
return out , nil
}
func ( c * providerClient ) InvokeAction ( ctx context . Context , in * InvokeAction_Request , opts ... grpc . CallOption ) ( Provider_InvokeActionClient , error ) {
stream , err := c . cc . NewStream ( ctx , & Provider_ServiceDesc . Streams [ 3 ] , Provider_InvokeAction_FullMethodName , opts ... )
func ( c * providerClient ) InvokeAction ( ctx context . Context , in * InvokeAction_Request , opts ... grpc . CallOption ) ( grpc . ServerStreamingClient [ InvokeAction_Event ] , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
stream , err := c . cc . NewStream ( ctx , & Provider_ServiceDesc . Streams [ 3 ] , Provider_InvokeAction_FullMethodName , cOpts ... )
if err != nil {
return nil , err
}
x := & providerInvokeActionClient{ stream }
x := & grpc. GenericClientStream [ InvokeAction_Request , InvokeAction_Event ] { ClientStream : stream }
if err := x . ClientStream . SendMsg ( in ) ; err != nil {
return nil , err
}
@ -538,26 +522,13 @@ func (c *providerClient) InvokeAction(ctx context.Context, in *InvokeAction_Requ
return x , nil
}
type Provider_InvokeActionClient interface {
Recv ( ) ( * InvokeAction_Event , error )
grpc . ClientStream
}
type providerInvokeActionClient struct {
grpc . ClientStream
}
func ( x * providerInvokeActionClient ) Recv ( ) ( * InvokeAction_Event , error ) {
m := new ( InvokeAction_Event )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Provider_InvokeActionClient = grpc . ServerStreamingClient [ InvokeAction_Event ]
func ( c * providerClient ) ValidateActionConfig ( ctx context . Context , in * ValidateActionConfig_Request , opts ... grpc . CallOption ) ( * ValidateActionConfig_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( ValidateActionConfig_Response )
err := c . cc . Invoke ( ctx , Provider_ValidateActionConfig_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_ValidateActionConfig_FullMethodName , in , out , cOpts ... )
if err != nil {
return nil , err
}
@ -565,8 +536,9 @@ func (c *providerClient) ValidateActionConfig(ctx context.Context, in *ValidateA
}
func ( c * providerClient ) StopProvider ( ctx context . Context , in * StopProvider_Request , opts ... grpc . CallOption ) ( * StopProvider_Response , error ) {
cOpts := append ( [ ] grpc . CallOption { grpc . StaticMethod ( ) } , opts ... )
out := new ( StopProvider_Response )
err := c . cc . Invoke ( ctx , Provider_StopProvider_FullMethodName , in , out , o pts... )
err := c . cc . Invoke ( ctx , Provider_StopProvider_FullMethodName , in , out , cO pts... )
if err != nil {
return nil , err
}
@ -575,7 +547,7 @@ func (c *providerClient) StopProvider(ctx context.Context, in *StopProvider_Requ
// ProviderServer is the server API for Provider service.
// All implementations must embed UnimplementedProviderServer
// for forward compatibility
// for forward compatibility .
type ProviderServer interface {
// GetMetadata returns upfront information about server capabilities and
// supported resource types without requiring the server to instantiate all
@ -612,7 +584,7 @@ type ProviderServer interface {
RenewEphemeralResource ( context . Context , * RenewEphemeralResource_Request ) ( * RenewEphemeralResource_Response , error )
CloseEphemeralResource ( context . Context , * CloseEphemeralResource_Request ) ( * CloseEphemeralResource_Response , error )
// ///// List
ListResource ( * ListResource_Request , Provider_ListResourceServer ) error
ListResource ( * ListResource_Request , grpc. ServerStreamingServer [ ListResource_Event ] ) error
ValidateListResourceConfig ( context . Context , * ValidateListResourceConfig_Request ) ( * ValidateListResourceConfig_Response , error )
// GetFunctions returns the definitions of all functions.
GetFunctions ( context . Context , * GetFunctions_Request ) ( * GetFunctions_Response , error )
@ -623,9 +595,9 @@ type ProviderServer interface {
// ConfigureStateStore configures the state store, such as S3 connection in the context of already configured provider
ConfigureStateStore ( context . Context , * ConfigureStateStore_Request ) ( * ConfigureStateStore_Response , error )
// ReadStateBytes streams byte chunks of a given state file from a state store
ReadStateBytes ( * ReadStateBytes_Request , Provider_ReadStateBytesServer ) error
ReadStateBytes ( * ReadStateBytes_Request , grpc. ServerStreamingServer [ ReadStateBytes_Response ] ) error
// WriteStateBytes streams byte chunks of a given state file into a state store
WriteStateBytes ( Provider_WriteStateBytesServer ) error
WriteStateBytes ( grpc. ClientStreamingServer [ WriteStateBytes_RequestChunk , WriteStateBytes_Response ] ) error
// LockState locks a given state (i.e. CE workspace)
LockState ( context . Context , * LockState_Request ) ( * LockState_Response , error )
// UnlockState unlocks a given state (i.e. CE workspace)
@ -636,16 +608,19 @@ type ProviderServer interface {
DeleteState ( context . Context , * DeleteState_Request ) ( * DeleteState_Response , error )
// ////// Actions
PlanAction ( context . Context , * PlanAction_Request ) ( * PlanAction_Response , error )
InvokeAction ( * InvokeAction_Request , Provider_InvokeActionServer ) error
InvokeAction ( * InvokeAction_Request , grpc. ServerStreamingServer [ InvokeAction_Event ] ) error
ValidateActionConfig ( context . Context , * ValidateActionConfig_Request ) ( * ValidateActionConfig_Response , error )
// ////// Graceful Shutdown
StopProvider ( context . Context , * StopProvider_Request ) ( * StopProvider_Response , error )
mustEmbedUnimplementedProviderServer ( )
}
// UnimplementedProviderServer must be embedded to have forward compatible implementations.
type UnimplementedProviderServer struct {
}
// UnimplementedProviderServer must be embedded to have
// forward compatible implementations.
//
// NOTE: this should be embedded by value instead of pointer to avoid a nil
// pointer dereference when methods are called.
type UnimplementedProviderServer struct { }
func ( UnimplementedProviderServer ) GetMetadata ( context . Context , * GetMetadata_Request ) ( * GetMetadata_Response , error ) {
return nil , status . Errorf ( codes . Unimplemented , "method GetMetadata not implemented" )
@ -707,7 +682,7 @@ func (UnimplementedProviderServer) RenewEphemeralResource(context.Context, *Rene
func ( UnimplementedProviderServer ) CloseEphemeralResource ( context . Context , * CloseEphemeralResource_Request ) ( * CloseEphemeralResource_Response , error ) {
return nil , status . Errorf ( codes . Unimplemented , "method CloseEphemeralResource not implemented" )
}
func ( UnimplementedProviderServer ) ListResource ( * ListResource_Request , Provider_ListResourceServer ) error {
func ( UnimplementedProviderServer ) ListResource ( * ListResource_Request , grpc. ServerStreamingServer [ ListResource_Event ] ) error {
return status . Errorf ( codes . Unimplemented , "method ListResource not implemented" )
}
func ( UnimplementedProviderServer ) ValidateListResourceConfig ( context . Context , * ValidateListResourceConfig_Request ) ( * ValidateListResourceConfig_Response , error ) {
@ -725,10 +700,10 @@ func (UnimplementedProviderServer) ValidateStateStoreConfig(context.Context, *Va
func ( UnimplementedProviderServer ) ConfigureStateStore ( context . Context , * ConfigureStateStore_Request ) ( * ConfigureStateStore_Response , error ) {
return nil , status . Errorf ( codes . Unimplemented , "method ConfigureStateStore not implemented" )
}
func ( UnimplementedProviderServer ) ReadStateBytes ( * ReadStateBytes_Request , Provider_ReadStateBytesServer ) error {
func ( UnimplementedProviderServer ) ReadStateBytes ( * ReadStateBytes_Request , grpc. ServerStreamingServer [ ReadStateBytes_Response ] ) error {
return status . Errorf ( codes . Unimplemented , "method ReadStateBytes not implemented" )
}
func ( UnimplementedProviderServer ) WriteStateBytes ( Provider_WriteStateBytesServer ) error {
func ( UnimplementedProviderServer ) WriteStateBytes ( grpc. ClientStreamingServer [ WriteStateBytes_RequestChunk , WriteStateBytes_Response ] ) error {
return status . Errorf ( codes . Unimplemented , "method WriteStateBytes not implemented" )
}
func ( UnimplementedProviderServer ) LockState ( context . Context , * LockState_Request ) ( * LockState_Response , error ) {
@ -746,7 +721,7 @@ func (UnimplementedProviderServer) DeleteState(context.Context, *DeleteState_Req
func ( UnimplementedProviderServer ) PlanAction ( context . Context , * PlanAction_Request ) ( * PlanAction_Response , error ) {
return nil , status . Errorf ( codes . Unimplemented , "method PlanAction not implemented" )
}
func ( UnimplementedProviderServer ) InvokeAction ( * InvokeAction_Request , Provider_InvokeActionServer ) error {
func ( UnimplementedProviderServer ) InvokeAction ( * InvokeAction_Request , grpc. ServerStreamingServer [ InvokeAction_Event ] ) error {
return status . Errorf ( codes . Unimplemented , "method InvokeAction not implemented" )
}
func ( UnimplementedProviderServer ) ValidateActionConfig ( context . Context , * ValidateActionConfig_Request ) ( * ValidateActionConfig_Response , error ) {
@ -756,6 +731,7 @@ func (UnimplementedProviderServer) StopProvider(context.Context, *StopProvider_R
return nil , status . Errorf ( codes . Unimplemented , "method StopProvider not implemented" )
}
func ( UnimplementedProviderServer ) mustEmbedUnimplementedProviderServer ( ) { }
func ( UnimplementedProviderServer ) testEmbeddedByValue ( ) { }
// 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
@ -765,6 +741,13 @@ type UnsafeProviderServer interface {
}
func RegisterProviderServer ( s grpc . ServiceRegistrar , srv ProviderServer ) {
// If the following call pancis, it indicates UnimplementedProviderServer was
// embedded by pointer and is nil. This will cause panics if an
// unimplemented method is ever invoked, so we test this at initialization
// time to prevent it from happening at runtime later due to I/O.
if t , ok := srv . ( interface { testEmbeddedByValue ( ) } ) ; ok {
t . testEmbeddedByValue ( )
}
s . RegisterService ( & Provider_ServiceDesc , srv )
}
@ -1133,21 +1116,11 @@ func _Provider_ListResource_Handler(srv interface{}, stream grpc.ServerStream) e
if err := stream . RecvMsg ( m ) ; err != nil {
return err
}
return srv . ( ProviderServer ) . ListResource ( m , & providerListResourceServer{ stream } )
return srv . ( ProviderServer ) . ListResource ( m , & grpc. GenericServerStream [ ListResource_Request , ListResource_Event ] { ServerStream : stream } )
}
type Provider_ListResourceServer interface {
Send ( * ListResource_Event ) error
grpc . ServerStream
}
type providerListResourceServer struct {
grpc . ServerStream
}
func ( x * providerListResourceServer ) Send ( m * ListResource_Event ) error {
return x . ServerStream . SendMsg ( m )
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Provider_ListResourceServer = grpc . ServerStreamingServer [ ListResource_Event ]
func _Provider_ValidateListResourceConfig_Handler ( srv interface { } , ctx context . Context , dec func ( interface { } ) error , interceptor grpc . UnaryServerInterceptor ) ( interface { } , error ) {
in := new ( ValidateListResourceConfig_Request )
@ -1244,47 +1217,18 @@ func _Provider_ReadStateBytes_Handler(srv interface{}, stream grpc.ServerStream)
if err := stream . RecvMsg ( m ) ; err != nil {
return err
}
return srv . ( ProviderServer ) . ReadStateBytes ( m , & providerReadStateBytesServer { stream } )
}
type Provider_ReadStateBytesServer interface {
Send ( * ReadStateBytes_Response ) error
grpc . ServerStream
}
type providerReadStateBytesServer struct {
grpc . ServerStream
return srv . ( ProviderServer ) . ReadStateBytes ( m , & grpc . GenericServerStream [ ReadStateBytes_Request , ReadStateBytes_Response ] { ServerStream : stream } )
}
func ( x * providerReadStateBytesServer ) Send ( m * ReadStateBytes_Response ) error {
return x . ServerStream . SendMsg ( m )
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Provider_ReadStateBytesServer = grpc . ServerStreamingServer [ ReadStateBytes_Response ]
func _Provider_WriteStateBytes_Handler ( srv interface { } , stream grpc . ServerStream ) error {
return srv . ( ProviderServer ) . WriteStateBytes ( & providerWriteStateBytesServer { stream } )
}
type Provider_WriteStateBytesServer interface {
SendAndClose ( * WriteStateBytes_Response ) error
Recv ( ) ( * WriteStateBytes_RequestChunk , error )
grpc . ServerStream
}
type providerWriteStateBytesServer struct {
grpc . ServerStream
return srv . ( ProviderServer ) . WriteStateBytes ( & grpc . GenericServerStream [ WriteStateBytes_RequestChunk , WriteStateBytes_Response ] { ServerStream : stream } )
}
func ( x * providerWriteStateBytesServer ) SendAndClose ( m * WriteStateBytes_Response ) error {
return x . ServerStream . SendMsg ( m )
}
func ( x * providerWriteStateBytesServer ) Recv ( ) ( * WriteStateBytes_RequestChunk , error ) {
m := new ( WriteStateBytes_RequestChunk )
if err := x . ServerStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Provider_WriteStateBytesServer = grpc . ClientStreamingServer [ WriteStateBytes_RequestChunk , WriteStateBytes_Response ]
func _Provider_LockState_Handler ( srv interface { } , ctx context . Context , dec func ( interface { } ) error , interceptor grpc . UnaryServerInterceptor ) ( interface { } , error ) {
in := new ( LockState_Request )
@ -1381,21 +1325,11 @@ func _Provider_InvokeAction_Handler(srv interface{}, stream grpc.ServerStream) e
if err := stream . RecvMsg ( m ) ; err != nil {
return err
}
return srv . ( ProviderServer ) . InvokeAction ( m , & providerInvokeActionServer { stream } )
}
type Provider_InvokeActionServer interface {
Send ( * InvokeAction_Event ) error
grpc . ServerStream
return srv . ( ProviderServer ) . InvokeAction ( m , & grpc . GenericServerStream [ InvokeAction_Request , InvokeAction_Event ] { ServerStream : stream } )
}
type providerInvokeActionServer struct {
grpc . ServerStream
}
func ( x * providerInvokeActionServer ) Send ( m * InvokeAction_Event ) error {
return x . ServerStream . SendMsg ( m )
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Provider_InvokeActionServer = grpc . ServerStreamingServer [ InvokeAction_Event ]
func _Provider_ValidateActionConfig_Handler ( srv interface { } , ctx context . Context , dec func ( interface { } ) error , interceptor grpc . UnaryServerInterceptor ) ( interface { } , error ) {
in := new ( ValidateActionConfig_Request )
Sarah French
6 months ago
committed by
GitHub