Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterPostgresServer(s grpc.ServiceRegistrar, srv PostgresServer)
- type EnrichConfigurationRequest
- func (*EnrichConfigurationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EnrichConfigurationRequest) GetClusterDefinition() []byte
- func (x *EnrichConfigurationRequest) GetConfigs() map[string]string
- func (x *EnrichConfigurationRequest) GetOperationType() *OperationType
- func (*EnrichConfigurationRequest) ProtoMessage()
- func (x *EnrichConfigurationRequest) ProtoReflect() protoreflect.Message
- func (x *EnrichConfigurationRequest) Reset()
- func (x *EnrichConfigurationRequest) String() string
- type EnrichConfigurationResult
- func (*EnrichConfigurationResult) Descriptor() ([]byte, []int)deprecated
- func (x *EnrichConfigurationResult) GetConfigs() map[string]string
- func (*EnrichConfigurationResult) ProtoMessage()
- func (x *EnrichConfigurationResult) ProtoReflect() protoreflect.Message
- func (x *EnrichConfigurationResult) Reset()
- func (x *EnrichConfigurationResult) String() string
- type OperationType
- type OperationType_Type
- func (OperationType_Type) Descriptor() protoreflect.EnumDescriptor
- func (x OperationType_Type) Enum() *OperationType_Type
- func (OperationType_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x OperationType_Type) Number() protoreflect.EnumNumber
- func (x OperationType_Type) String() string
- func (OperationType_Type) Type() protoreflect.EnumType
- type PostgresCapabilitiesRequest
- type PostgresCapabilitiesResult
- func (*PostgresCapabilitiesResult) Descriptor() ([]byte, []int)deprecated
- func (x *PostgresCapabilitiesResult) GetCapabilities() []*PostgresCapability
- func (*PostgresCapabilitiesResult) ProtoMessage()
- func (x *PostgresCapabilitiesResult) ProtoReflect() protoreflect.Message
- func (x *PostgresCapabilitiesResult) Reset()
- func (x *PostgresCapabilitiesResult) String() string
- type PostgresCapability
- func (*PostgresCapability) Descriptor() ([]byte, []int)deprecated
- func (x *PostgresCapability) GetRpc() *PostgresCapability_RPC
- func (x *PostgresCapability) GetType() isPostgresCapability_Type
- func (*PostgresCapability) ProtoMessage()
- func (x *PostgresCapability) ProtoReflect() protoreflect.Message
- func (x *PostgresCapability) Reset()
- func (x *PostgresCapability) String() string
- type PostgresCapability_RPC
- func (*PostgresCapability_RPC) Descriptor() ([]byte, []int)deprecated
- func (x *PostgresCapability_RPC) GetType() PostgresCapability_RPC_Type
- func (*PostgresCapability_RPC) ProtoMessage()
- func (x *PostgresCapability_RPC) ProtoReflect() protoreflect.Message
- func (x *PostgresCapability_RPC) Reset()
- func (x *PostgresCapability_RPC) String() string
- type PostgresCapability_RPC_Type
- func (PostgresCapability_RPC_Type) Descriptor() protoreflect.EnumDescriptor
- func (x PostgresCapability_RPC_Type) Enum() *PostgresCapability_RPC_Type
- func (PostgresCapability_RPC_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x PostgresCapability_RPC_Type) Number() protoreflect.EnumNumber
- func (x PostgresCapability_RPC_Type) String() string
- func (PostgresCapability_RPC_Type) Type() protoreflect.EnumType
- type PostgresCapability_Rpc
- type PostgresClient
- type PostgresServer
- type UnimplementedPostgresServer
- type UnsafePostgresServer
Constants ¶
const ( Postgres_GetCapabilities_FullMethodName = "/cnpgi.identity.v1.Postgres/GetCapabilities" Postgres_EnrichConfiguration_FullMethodName = "/cnpgi.identity.v1.Postgres/EnrichConfiguration" )
Variables ¶
var ( PostgresCapability_RPC_Type_name = map[int32]string{ 0: "TYPE_UNSPECIFIED", 1: "TYPE_ENRICH_CONFIGURATION", } PostgresCapability_RPC_Type_value = map[string]int32{ "TYPE_UNSPECIFIED": 0, "TYPE_ENRICH_CONFIGURATION": 1, } )
Enum value maps for PostgresCapability_RPC_Type.
var ( OperationType_Type_name = map[int32]string{ 0: "TYPE_UNSPECIFIED", 1: "TYPE_INIT", 2: "TYPE_RESTORE", 3: "TYPE_RECONCILE", 4: "TYPE_UPGRADE", } OperationType_Type_value = map[string]int32{ "TYPE_UNSPECIFIED": 0, "TYPE_INIT": 1, "TYPE_RESTORE": 2, "TYPE_RECONCILE": 3, "TYPE_UPGRADE": 4, } )
Enum value maps for OperationType_Type.
var File_proto_postgres_proto protoreflect.FileDescriptor
var Postgres_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cnpgi.identity.v1.Postgres", HandlerType: (*PostgresServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetCapabilities", Handler: _Postgres_GetCapabilities_Handler, }, { MethodName: "EnrichConfiguration", Handler: _Postgres_EnrichConfiguration_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/postgres.proto", }
Postgres_ServiceDesc is the grpc.ServiceDesc for Postgres service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPostgresServer ¶
func RegisterPostgresServer(s grpc.ServiceRegistrar, srv PostgresServer)
Types ¶
type EnrichConfigurationRequest ¶
type EnrichConfigurationRequest struct {
// This field is REQUIRED and represent the PostgreSQL configuration parameters as
// generated by the instance manager
Configs map[string]string `` /* 141-byte string literal not displayed */
// This field is REQUIRED
ClusterDefinition []byte `protobuf:"bytes,2,opt,name=cluster_definition,json=clusterDefinition,proto3" json:"cluster_definition,omitempty"`
// This field is REQUIRED.
OperationType *OperationType `protobuf:"bytes,3,opt,name=operation_type,json=operationType,proto3" json:"operation_type,omitempty"`
// contains filtered or unexported fields
}
func (*EnrichConfigurationRequest) Descriptor
deprecated
func (*EnrichConfigurationRequest) Descriptor() ([]byte, []int)
Deprecated: Use EnrichConfigurationRequest.ProtoReflect.Descriptor instead.
func (*EnrichConfigurationRequest) GetClusterDefinition ¶ added in v0.3.0
func (x *EnrichConfigurationRequest) GetClusterDefinition() []byte
func (*EnrichConfigurationRequest) GetConfigs ¶
func (x *EnrichConfigurationRequest) GetConfigs() map[string]string
func (*EnrichConfigurationRequest) GetOperationType ¶ added in v0.3.0
func (x *EnrichConfigurationRequest) GetOperationType() *OperationType
func (*EnrichConfigurationRequest) ProtoMessage ¶
func (*EnrichConfigurationRequest) ProtoMessage()
func (*EnrichConfigurationRequest) ProtoReflect ¶
func (x *EnrichConfigurationRequest) ProtoReflect() protoreflect.Message
func (*EnrichConfigurationRequest) Reset ¶
func (x *EnrichConfigurationRequest) Reset()
func (*EnrichConfigurationRequest) String ¶
func (x *EnrichConfigurationRequest) String() string
type EnrichConfigurationResult ¶
type EnrichConfigurationResult struct {
// This field is OPTIONAL. Returns the new configuration.
Configs map[string]string `` /* 141-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*EnrichConfigurationResult) Descriptor
deprecated
func (*EnrichConfigurationResult) Descriptor() ([]byte, []int)
Deprecated: Use EnrichConfigurationResult.ProtoReflect.Descriptor instead.
func (*EnrichConfigurationResult) GetConfigs ¶
func (x *EnrichConfigurationResult) GetConfigs() map[string]string
func (*EnrichConfigurationResult) ProtoMessage ¶
func (*EnrichConfigurationResult) ProtoMessage()
func (*EnrichConfigurationResult) ProtoReflect ¶
func (x *EnrichConfigurationResult) ProtoReflect() protoreflect.Message
func (*EnrichConfigurationResult) Reset ¶
func (x *EnrichConfigurationResult) Reset()
func (*EnrichConfigurationResult) String ¶
func (x *EnrichConfigurationResult) String() string
type OperationType ¶ added in v0.3.0
type OperationType struct {
Type OperationType_Type `protobuf:"varint,1,opt,name=type,proto3,enum=cnpgi.identity.v1.OperationType_Type" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*OperationType) Descriptor
deprecated
added in
v0.3.0
func (*OperationType) Descriptor() ([]byte, []int)
Deprecated: Use OperationType.ProtoReflect.Descriptor instead.
func (*OperationType) GetType ¶ added in v0.3.0
func (x *OperationType) GetType() OperationType_Type
func (*OperationType) ProtoMessage ¶ added in v0.3.0
func (*OperationType) ProtoMessage()
func (*OperationType) ProtoReflect ¶ added in v0.3.0
func (x *OperationType) ProtoReflect() protoreflect.Message
func (*OperationType) Reset ¶ added in v0.3.0
func (x *OperationType) Reset()
func (*OperationType) String ¶ added in v0.3.0
func (x *OperationType) String() string
type OperationType_Type ¶ added in v0.3.0
type OperationType_Type int32
const ( OperationType_TYPE_UNSPECIFIED OperationType_Type = 0 OperationType_TYPE_INIT OperationType_Type = 1 OperationType_TYPE_RESTORE OperationType_Type = 2 OperationType_TYPE_RECONCILE OperationType_Type = 3 OperationType_TYPE_UPGRADE OperationType_Type = 4 )
func (OperationType_Type) Descriptor ¶ added in v0.3.0
func (OperationType_Type) Descriptor() protoreflect.EnumDescriptor
func (OperationType_Type) Enum ¶ added in v0.3.0
func (x OperationType_Type) Enum() *OperationType_Type
func (OperationType_Type) EnumDescriptor
deprecated
added in
v0.3.0
func (OperationType_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use OperationType_Type.Descriptor instead.
func (OperationType_Type) Number ¶ added in v0.3.0
func (x OperationType_Type) Number() protoreflect.EnumNumber
func (OperationType_Type) String ¶ added in v0.3.0
func (x OperationType_Type) String() string
func (OperationType_Type) Type ¶ added in v0.3.0
func (OperationType_Type) Type() protoreflect.EnumType
type PostgresCapabilitiesRequest ¶
type PostgresCapabilitiesRequest struct {
// contains filtered or unexported fields
}
func (*PostgresCapabilitiesRequest) Descriptor
deprecated
func (*PostgresCapabilitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use PostgresCapabilitiesRequest.ProtoReflect.Descriptor instead.
func (*PostgresCapabilitiesRequest) ProtoMessage ¶
func (*PostgresCapabilitiesRequest) ProtoMessage()
func (*PostgresCapabilitiesRequest) ProtoReflect ¶
func (x *PostgresCapabilitiesRequest) ProtoReflect() protoreflect.Message
func (*PostgresCapabilitiesRequest) Reset ¶
func (x *PostgresCapabilitiesRequest) Reset()
func (*PostgresCapabilitiesRequest) String ¶
func (x *PostgresCapabilitiesRequest) String() string
type PostgresCapabilitiesResult ¶
type PostgresCapabilitiesResult struct {
// All the capabilities that the controller service supports. This
// field is OPTIONAL.
Capabilities []*PostgresCapability `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
// contains filtered or unexported fields
}
func (*PostgresCapabilitiesResult) Descriptor
deprecated
func (*PostgresCapabilitiesResult) Descriptor() ([]byte, []int)
Deprecated: Use PostgresCapabilitiesResult.ProtoReflect.Descriptor instead.
func (*PostgresCapabilitiesResult) GetCapabilities ¶
func (x *PostgresCapabilitiesResult) GetCapabilities() []*PostgresCapability
func (*PostgresCapabilitiesResult) ProtoMessage ¶
func (*PostgresCapabilitiesResult) ProtoMessage()
func (*PostgresCapabilitiesResult) ProtoReflect ¶
func (x *PostgresCapabilitiesResult) ProtoReflect() protoreflect.Message
func (*PostgresCapabilitiesResult) Reset ¶
func (x *PostgresCapabilitiesResult) Reset()
func (*PostgresCapabilitiesResult) String ¶
func (x *PostgresCapabilitiesResult) String() string
type PostgresCapability ¶
type PostgresCapability struct {
// Types that are valid to be assigned to Type:
//
// *PostgresCapability_Rpc
Type isPostgresCapability_Type `protobuf_oneof:"type"`
// contains filtered or unexported fields
}
func (*PostgresCapability) Descriptor
deprecated
func (*PostgresCapability) Descriptor() ([]byte, []int)
Deprecated: Use PostgresCapability.ProtoReflect.Descriptor instead.
func (*PostgresCapability) GetRpc ¶
func (x *PostgresCapability) GetRpc() *PostgresCapability_RPC
func (*PostgresCapability) GetType ¶
func (x *PostgresCapability) GetType() isPostgresCapability_Type
func (*PostgresCapability) ProtoMessage ¶
func (*PostgresCapability) ProtoMessage()
func (*PostgresCapability) ProtoReflect ¶
func (x *PostgresCapability) ProtoReflect() protoreflect.Message
func (*PostgresCapability) Reset ¶
func (x *PostgresCapability) Reset()
func (*PostgresCapability) String ¶
func (x *PostgresCapability) String() string
type PostgresCapability_RPC ¶
type PostgresCapability_RPC struct {
Type PostgresCapability_RPC_Type `protobuf:"varint,1,opt,name=type,proto3,enum=cnpgi.identity.v1.PostgresCapability_RPC_Type" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*PostgresCapability_RPC) Descriptor
deprecated
func (*PostgresCapability_RPC) Descriptor() ([]byte, []int)
Deprecated: Use PostgresCapability_RPC.ProtoReflect.Descriptor instead.
func (*PostgresCapability_RPC) GetType ¶
func (x *PostgresCapability_RPC) GetType() PostgresCapability_RPC_Type
func (*PostgresCapability_RPC) ProtoMessage ¶
func (*PostgresCapability_RPC) ProtoMessage()
func (*PostgresCapability_RPC) ProtoReflect ¶
func (x *PostgresCapability_RPC) ProtoReflect() protoreflect.Message
func (*PostgresCapability_RPC) Reset ¶
func (x *PostgresCapability_RPC) Reset()
func (*PostgresCapability_RPC) String ¶
func (x *PostgresCapability_RPC) String() string
type PostgresCapability_RPC_Type ¶
type PostgresCapability_RPC_Type int32
const ( PostgresCapability_RPC_TYPE_UNSPECIFIED PostgresCapability_RPC_Type = 0 // TYPE_BACKUP indicates that the Plugin is able to // enrich the PostgreSQL configuration via the // EnrichConfiguration endpoint PostgresCapability_RPC_TYPE_ENRICH_CONFIGURATION PostgresCapability_RPC_Type = 1 )
func (PostgresCapability_RPC_Type) Descriptor ¶
func (PostgresCapability_RPC_Type) Descriptor() protoreflect.EnumDescriptor
func (PostgresCapability_RPC_Type) Enum ¶
func (x PostgresCapability_RPC_Type) Enum() *PostgresCapability_RPC_Type
func (PostgresCapability_RPC_Type) EnumDescriptor
deprecated
func (PostgresCapability_RPC_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use PostgresCapability_RPC_Type.Descriptor instead.
func (PostgresCapability_RPC_Type) Number ¶
func (x PostgresCapability_RPC_Type) Number() protoreflect.EnumNumber
func (PostgresCapability_RPC_Type) String ¶
func (x PostgresCapability_RPC_Type) String() string
func (PostgresCapability_RPC_Type) Type ¶
func (PostgresCapability_RPC_Type) Type() protoreflect.EnumType
type PostgresCapability_Rpc ¶
type PostgresCapability_Rpc struct {
Rpc *PostgresCapability_RPC `protobuf:"bytes,1,opt,name=rpc,proto3,oneof"`
}
type PostgresClient ¶
type PostgresClient interface {
// GetCapabilities gets the capabilities of the Backup service
GetCapabilities(ctx context.Context, in *PostgresCapabilitiesRequest, opts ...grpc.CallOption) (*PostgresCapabilitiesResult, error)
// EnrichConfiguration is called before applying the configuration
// to PostgreSQL
EnrichConfiguration(ctx context.Context, in *EnrichConfigurationRequest, opts ...grpc.CallOption) (*EnrichConfigurationResult, error)
}
PostgresClient is the client API for Postgres 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.
func NewPostgresClient ¶
func NewPostgresClient(cc grpc.ClientConnInterface) PostgresClient
type PostgresServer ¶
type PostgresServer interface {
// GetCapabilities gets the capabilities of the Backup service
GetCapabilities(context.Context, *PostgresCapabilitiesRequest) (*PostgresCapabilitiesResult, error)
// EnrichConfiguration is called before applying the configuration
// to PostgreSQL
EnrichConfiguration(context.Context, *EnrichConfigurationRequest) (*EnrichConfigurationResult, error)
// contains filtered or unexported methods
}
PostgresServer is the server API for Postgres service. All implementations must embed UnimplementedPostgresServer for forward compatibility.
type UnimplementedPostgresServer ¶
type UnimplementedPostgresServer struct{}
UnimplementedPostgresServer 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.
func (UnimplementedPostgresServer) EnrichConfiguration ¶
func (UnimplementedPostgresServer) EnrichConfiguration(context.Context, *EnrichConfigurationRequest) (*EnrichConfigurationResult, error)
func (UnimplementedPostgresServer) GetCapabilities ¶
func (UnimplementedPostgresServer) GetCapabilities(context.Context, *PostgresCapabilitiesRequest) (*PostgresCapabilitiesResult, error)
type UnsafePostgresServer ¶
type UnsafePostgresServer interface {
// contains filtered or unexported methods
}
UnsafePostgresServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PostgresServer will result in compilation errors.