Documentation ¶
Index ¶
- Variables
- func RegisterSchemasServiceServer(s grpc.ServiceRegistrar, srv SchemasServiceServer)
- type ActivateSchemaRequest
- func (*ActivateSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActivateSchemaRequest) GetBillingId() stringdeprecated
- func (x *ActivateSchemaRequest) GetProjectId() string
- func (x *ActivateSchemaRequest) GetSchemaRef() *v1.SchemaRef
- func (*ActivateSchemaRequest) ProtoMessage()
- func (x *ActivateSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *ActivateSchemaRequest) Reset()
- func (x *ActivateSchemaRequest) String() string
- type ActivateSchemaResponse
- type ArchiveSchemaRequest
- func (*ArchiveSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ArchiveSchemaRequest) GetBillingId() stringdeprecated
- func (x *ArchiveSchemaRequest) GetProjectId() string
- func (x *ArchiveSchemaRequest) GetSchemaRef() *v1.SchemaRef
- func (*ArchiveSchemaRequest) ProtoMessage()
- func (x *ArchiveSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *ArchiveSchemaRequest) Reset()
- func (x *ArchiveSchemaRequest) String() string
- type ArchiveSchemaResponse
- type CreateSchemaRequest
- func (*CreateSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSchemaRequest) GetBillingId() stringdeprecated
- func (x *CreateSchemaRequest) GetProjectId() string
- func (x *CreateSchemaRequest) GetSchema() *v1.Schema
- func (*CreateSchemaRequest) ProtoMessage()
- func (x *CreateSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSchemaRequest) Reset()
- func (x *CreateSchemaRequest) String() string
- type CreateSchemaResponse
- func (*CreateSchemaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSchemaResponse) GetChecksum() string
- func (x *CreateSchemaResponse) GetSchema() *v1.Schema
- func (*CreateSchemaResponse) ProtoMessage()
- func (x *CreateSchemaResponse) ProtoReflect() protoreflect.Message
- func (x *CreateSchemaResponse) Reset()
- func (x *CreateSchemaResponse) String() string
- type DeleteSchemaRequest
- func (*DeleteSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSchemaRequest) GetBillingId() stringdeprecated
- func (x *DeleteSchemaRequest) GetProjectId() string
- func (x *DeleteSchemaRequest) GetSchemaRef() *v1.SchemaRef
- func (*DeleteSchemaRequest) ProtoMessage()
- func (x *DeleteSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSchemaRequest) Reset()
- func (x *DeleteSchemaRequest) String() string
- type DeleteSchemaResponse
- type GetSchemaCodeRequest
- func (*GetSchemaCodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemaCodeRequest) GetBillingId() stringdeprecated
- func (x *GetSchemaCodeRequest) GetLanguage() string
- func (x *GetSchemaCodeRequest) GetRef() *v1.SchemaRef
- func (*GetSchemaCodeRequest) ProtoMessage()
- func (x *GetSchemaCodeRequest) ProtoReflect() protoreflect.Message
- func (x *GetSchemaCodeRequest) Reset()
- func (x *GetSchemaCodeRequest) String() string
- type GetSchemaCodeResponse
- func (*GetSchemaCodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemaCodeResponse) GetData() []byte
- func (x *GetSchemaCodeResponse) GetDataSize() int64
- func (x *GetSchemaCodeResponse) GetFilename() string
- func (*GetSchemaCodeResponse) ProtoMessage()
- func (x *GetSchemaCodeResponse) ProtoReflect() protoreflect.Message
- func (x *GetSchemaCodeResponse) Reset()
- func (x *GetSchemaCodeResponse) String() string
- type GetSchemaDefinitionRequest
- func (*GetSchemaDefinitionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemaDefinitionRequest) GetClusterRef() *v1.KafkaClusterRef
- func (x *GetSchemaDefinitionRequest) GetConfluentId() int32
- func (*GetSchemaDefinitionRequest) ProtoMessage()
- func (x *GetSchemaDefinitionRequest) ProtoReflect() protoreflect.Message
- func (x *GetSchemaDefinitionRequest) Reset()
- func (x *GetSchemaDefinitionRequest) String() string
- type GetSchemaDefinitionResponse
- func (*GetSchemaDefinitionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemaDefinitionResponse) GetDefinition() string
- func (*GetSchemaDefinitionResponse) ProtoMessage()
- func (x *GetSchemaDefinitionResponse) ProtoReflect() protoreflect.Message
- func (x *GetSchemaDefinitionResponse) Reset()
- func (x *GetSchemaDefinitionResponse) String() string
- type GetSchemaRequest
- func (*GetSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemaRequest) GetBillingId() stringdeprecated
- func (x *GetSchemaRequest) GetClusterRef() *v1.KafkaClusterRef
- func (x *GetSchemaRequest) GetRef() *v1.SchemaRef
- func (*GetSchemaRequest) ProtoMessage()
- func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *GetSchemaRequest) Reset()
- func (x *GetSchemaRequest) String() string
- type GetSchemaResponse
- func (*GetSchemaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemaResponse) GetChecksum() string
- func (x *GetSchemaResponse) GetConfluentId() int32
- func (x *GetSchemaResponse) GetSchema() *v1.Schema
- func (*GetSchemaResponse) ProtoMessage()
- func (x *GetSchemaResponse) ProtoReflect() protoreflect.Message
- func (x *GetSchemaResponse) Reset()
- func (x *GetSchemaResponse) String() string
- type ListSchemasRequest
- func (*ListSchemasRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSchemasRequest) GetBillingId() string
- func (x *ListSchemasRequest) GetDomains() []string
- func (x *ListSchemasRequest) GetFilter() string
- func (x *ListSchemasRequest) GetHandle() string
- func (x *ListSchemasRequest) GetIndustries() []string
- func (x *ListSchemasRequest) GetLabels() []*v1.Label
- func (x *ListSchemasRequest) GetName() string
- func (x *ListSchemasRequest) GetPublicPrivate() v1.FilterPublicPrivate
- func (x *ListSchemasRequest) GetSchemaType() v1.SchemaType
- func (*ListSchemasRequest) ProtoMessage()
- func (x *ListSchemasRequest) ProtoReflect() protoreflect.Message
- func (x *ListSchemasRequest) Reset()
- func (x *ListSchemasRequest) String() string
- type ListSchemasResponse
- func (*ListSchemasResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSchemasResponse) GetSchemas() []*v1.Schema
- func (*ListSchemasResponse) ProtoMessage()
- func (x *ListSchemasResponse) ProtoReflect() protoreflect.Message
- func (x *ListSchemasResponse) Reset()
- func (x *ListSchemasResponse) String() string
- type SchemasServiceClient
- type SchemasServiceServer
- type UnimplementedSchemasServiceServer
- func (UnimplementedSchemasServiceServer) ActivateSchema(context.Context, *ActivateSchemaRequest) (*ActivateSchemaResponse, error)
- func (UnimplementedSchemasServiceServer) ArchiveSchema(context.Context, *ArchiveSchemaRequest) (*ArchiveSchemaResponse, error)
- func (UnimplementedSchemasServiceServer) CreateSchema(context.Context, *CreateSchemaRequest) (*CreateSchemaResponse, error)
- func (UnimplementedSchemasServiceServer) DeleteSchema(context.Context, *DeleteSchemaRequest) (*DeleteSchemaResponse, error)
- func (UnimplementedSchemasServiceServer) GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
- func (UnimplementedSchemasServiceServer) GetSchemaCode(context.Context, *GetSchemaCodeRequest) (*GetSchemaCodeResponse, error)
- func (UnimplementedSchemasServiceServer) GetSchemaDefinition(context.Context, *GetSchemaDefinitionRequest) (*GetSchemaDefinitionResponse, error)
- func (UnimplementedSchemasServiceServer) ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error)
- func (UnimplementedSchemasServiceServer) UpdateSchema(context.Context, *UpdateSchemaRequest) (*UpdateSchemaResponse, error)
- type UnsafeSchemasServiceServer
- type UpdateSchemaRequest
- func (*UpdateSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSchemaRequest) GetBillingId() stringdeprecated
- func (x *UpdateSchemaRequest) GetChecksum() string
- func (x *UpdateSchemaRequest) GetProjectId() string
- func (x *UpdateSchemaRequest) GetSchema() *v1.Schema
- func (x *UpdateSchemaRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateSchemaRequest) ProtoMessage()
- func (x *UpdateSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateSchemaRequest) Reset()
- func (x *UpdateSchemaRequest) String() string
- type UpdateSchemaResponse
- func (*UpdateSchemaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSchemaResponse) GetChecksum() string
- func (x *UpdateSchemaResponse) GetSchema() *v1.Schema
- func (*UpdateSchemaResponse) ProtoMessage()
- func (x *UpdateSchemaResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateSchemaResponse) Reset()
- func (x *UpdateSchemaResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var File_strmprivacy_api_schemas_v1_schemas_v1_proto protoreflect.FileDescriptor
var SchemasService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "strmprivacy.api.schemas.v1.SchemasService", HandlerType: (*SchemasServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListSchemas", Handler: _SchemasService_ListSchemas_Handler, }, { MethodName: "GetSchema", Handler: _SchemasService_GetSchema_Handler, }, { MethodName: "CreateSchema", Handler: _SchemasService_CreateSchema_Handler, }, { MethodName: "UpdateSchema", Handler: _SchemasService_UpdateSchema_Handler, }, { MethodName: "GetSchemaCode", Handler: _SchemasService_GetSchemaCode_Handler, }, { MethodName: "ActivateSchema", Handler: _SchemasService_ActivateSchema_Handler, }, { MethodName: "DeleteSchema", Handler: _SchemasService_DeleteSchema_Handler, }, { MethodName: "ArchiveSchema", Handler: _SchemasService_ArchiveSchema_Handler, }, { MethodName: "GetSchemaDefinition", Handler: _SchemasService_GetSchemaDefinition_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "strmprivacy/api/schemas/v1/schemas_v1.proto", }
SchemasService_ServiceDesc is the grpc.ServiceDesc for SchemasService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSchemasServiceServer ¶
func RegisterSchemasServiceServer(s grpc.ServiceRegistrar, srv SchemasServiceServer)
Types ¶
type ActivateSchemaRequest ¶ added in v2.19.0
type ActivateSchemaRequest struct { // Deprecated: Do not use. BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"` SchemaRef *v1.SchemaRef `protobuf:"bytes,2,opt,name=schema_ref,json=schemaRef,proto3" json:"schema_ref,omitempty"` ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // contains filtered or unexported fields }
func (*ActivateSchemaRequest) Descriptor
deprecated
added in
v2.19.0
func (*ActivateSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActivateSchemaRequest.ProtoReflect.Descriptor instead.
func (*ActivateSchemaRequest) GetBillingId
deprecated
added in
v2.19.0
func (x *ActivateSchemaRequest) GetBillingId() string
Deprecated: Do not use.
func (*ActivateSchemaRequest) GetProjectId ¶ added in v2.38.0
func (x *ActivateSchemaRequest) GetProjectId() string
func (*ActivateSchemaRequest) GetSchemaRef ¶ added in v2.19.0
func (x *ActivateSchemaRequest) GetSchemaRef() *v1.SchemaRef
func (*ActivateSchemaRequest) ProtoMessage ¶ added in v2.19.0
func (*ActivateSchemaRequest) ProtoMessage()
func (*ActivateSchemaRequest) ProtoReflect ¶ added in v2.19.0
func (x *ActivateSchemaRequest) ProtoReflect() protoreflect.Message
func (*ActivateSchemaRequest) Reset ¶ added in v2.19.0
func (x *ActivateSchemaRequest) Reset()
func (*ActivateSchemaRequest) String ¶ added in v2.19.0
func (x *ActivateSchemaRequest) String() string
type ActivateSchemaResponse ¶ added in v2.19.0
type ActivateSchemaResponse struct {
// contains filtered or unexported fields
}
func (*ActivateSchemaResponse) Descriptor
deprecated
added in
v2.19.0
func (*ActivateSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use ActivateSchemaResponse.ProtoReflect.Descriptor instead.
func (*ActivateSchemaResponse) ProtoMessage ¶ added in v2.19.0
func (*ActivateSchemaResponse) ProtoMessage()
func (*ActivateSchemaResponse) ProtoReflect ¶ added in v2.19.0
func (x *ActivateSchemaResponse) ProtoReflect() protoreflect.Message
func (*ActivateSchemaResponse) Reset ¶ added in v2.19.0
func (x *ActivateSchemaResponse) Reset()
func (*ActivateSchemaResponse) String ¶ added in v2.19.0
func (x *ActivateSchemaResponse) String() string
type ArchiveSchemaRequest ¶ added in v2.19.0
type ArchiveSchemaRequest struct { // Deprecated: Do not use. BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"` SchemaRef *v1.SchemaRef `protobuf:"bytes,2,opt,name=schema_ref,json=schemaRef,proto3" json:"schema_ref,omitempty"` ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // contains filtered or unexported fields }
func (*ArchiveSchemaRequest) Descriptor
deprecated
added in
v2.19.0
func (*ArchiveSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use ArchiveSchemaRequest.ProtoReflect.Descriptor instead.
func (*ArchiveSchemaRequest) GetBillingId
deprecated
added in
v2.19.0
func (x *ArchiveSchemaRequest) GetBillingId() string
Deprecated: Do not use.
func (*ArchiveSchemaRequest) GetProjectId ¶ added in v2.38.0
func (x *ArchiveSchemaRequest) GetProjectId() string
func (*ArchiveSchemaRequest) GetSchemaRef ¶ added in v2.19.0
func (x *ArchiveSchemaRequest) GetSchemaRef() *v1.SchemaRef
func (*ArchiveSchemaRequest) ProtoMessage ¶ added in v2.19.0
func (*ArchiveSchemaRequest) ProtoMessage()
func (*ArchiveSchemaRequest) ProtoReflect ¶ added in v2.19.0
func (x *ArchiveSchemaRequest) ProtoReflect() protoreflect.Message
func (*ArchiveSchemaRequest) Reset ¶ added in v2.19.0
func (x *ArchiveSchemaRequest) Reset()
func (*ArchiveSchemaRequest) String ¶ added in v2.19.0
func (x *ArchiveSchemaRequest) String() string
type ArchiveSchemaResponse ¶ added in v2.19.0
type ArchiveSchemaResponse struct {
// contains filtered or unexported fields
}
func (*ArchiveSchemaResponse) Descriptor
deprecated
added in
v2.19.0
func (*ArchiveSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use ArchiveSchemaResponse.ProtoReflect.Descriptor instead.
func (*ArchiveSchemaResponse) ProtoMessage ¶ added in v2.19.0
func (*ArchiveSchemaResponse) ProtoMessage()
func (*ArchiveSchemaResponse) ProtoReflect ¶ added in v2.19.0
func (x *ArchiveSchemaResponse) ProtoReflect() protoreflect.Message
func (*ArchiveSchemaResponse) Reset ¶ added in v2.19.0
func (x *ArchiveSchemaResponse) Reset()
func (*ArchiveSchemaResponse) String ¶ added in v2.19.0
func (x *ArchiveSchemaResponse) String() string
type CreateSchemaRequest ¶
type CreateSchemaRequest struct { // Deprecated: Do not use. BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"` Schema *v1.Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"` ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // contains filtered or unexported fields }
func (*CreateSchemaRequest) Descriptor
deprecated
func (*CreateSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSchemaRequest.ProtoReflect.Descriptor instead.
func (*CreateSchemaRequest) GetBillingId
deprecated
func (x *CreateSchemaRequest) GetBillingId() string
Deprecated: Do not use.
func (*CreateSchemaRequest) GetProjectId ¶ added in v2.38.0
func (x *CreateSchemaRequest) GetProjectId() string
func (*CreateSchemaRequest) GetSchema ¶
func (x *CreateSchemaRequest) GetSchema() *v1.Schema
func (*CreateSchemaRequest) ProtoMessage ¶
func (*CreateSchemaRequest) ProtoMessage()
func (*CreateSchemaRequest) ProtoReflect ¶
func (x *CreateSchemaRequest) ProtoReflect() protoreflect.Message
func (*CreateSchemaRequest) Reset ¶
func (x *CreateSchemaRequest) Reset()
func (*CreateSchemaRequest) String ¶
func (x *CreateSchemaRequest) String() string
type CreateSchemaResponse ¶
type CreateSchemaResponse struct { Schema *v1.Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` Checksum string `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"` // contains filtered or unexported fields }
func (*CreateSchemaResponse) Descriptor
deprecated
func (*CreateSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateSchemaResponse.ProtoReflect.Descriptor instead.
func (*CreateSchemaResponse) GetChecksum ¶
func (x *CreateSchemaResponse) GetChecksum() string
func (*CreateSchemaResponse) GetSchema ¶
func (x *CreateSchemaResponse) GetSchema() *v1.Schema
func (*CreateSchemaResponse) ProtoMessage ¶
func (*CreateSchemaResponse) ProtoMessage()
func (*CreateSchemaResponse) ProtoReflect ¶
func (x *CreateSchemaResponse) ProtoReflect() protoreflect.Message
func (*CreateSchemaResponse) Reset ¶
func (x *CreateSchemaResponse) Reset()
func (*CreateSchemaResponse) String ¶
func (x *CreateSchemaResponse) String() string
type DeleteSchemaRequest ¶ added in v2.19.0
type DeleteSchemaRequest struct { // Deprecated: Do not use. BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"` SchemaRef *v1.SchemaRef `protobuf:"bytes,2,opt,name=schema_ref,json=schemaRef,proto3" json:"schema_ref,omitempty"` ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // contains filtered or unexported fields }
func (*DeleteSchemaRequest) Descriptor
deprecated
added in
v2.19.0
func (*DeleteSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSchemaRequest.ProtoReflect.Descriptor instead.
func (*DeleteSchemaRequest) GetBillingId
deprecated
added in
v2.19.0
func (x *DeleteSchemaRequest) GetBillingId() string
Deprecated: Do not use.
func (*DeleteSchemaRequest) GetProjectId ¶ added in v2.38.0
func (x *DeleteSchemaRequest) GetProjectId() string
func (*DeleteSchemaRequest) GetSchemaRef ¶ added in v2.19.0
func (x *DeleteSchemaRequest) GetSchemaRef() *v1.SchemaRef
func (*DeleteSchemaRequest) ProtoMessage ¶ added in v2.19.0
func (*DeleteSchemaRequest) ProtoMessage()
func (*DeleteSchemaRequest) ProtoReflect ¶ added in v2.19.0
func (x *DeleteSchemaRequest) ProtoReflect() protoreflect.Message
func (*DeleteSchemaRequest) Reset ¶ added in v2.19.0
func (x *DeleteSchemaRequest) Reset()
func (*DeleteSchemaRequest) String ¶ added in v2.19.0
func (x *DeleteSchemaRequest) String() string
type DeleteSchemaResponse ¶ added in v2.19.0
type DeleteSchemaResponse struct {
// contains filtered or unexported fields
}
func (*DeleteSchemaResponse) Descriptor
deprecated
added in
v2.19.0
func (*DeleteSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSchemaResponse.ProtoReflect.Descriptor instead.
func (*DeleteSchemaResponse) ProtoMessage ¶ added in v2.19.0
func (*DeleteSchemaResponse) ProtoMessage()
func (*DeleteSchemaResponse) ProtoReflect ¶ added in v2.19.0
func (x *DeleteSchemaResponse) ProtoReflect() protoreflect.Message
func (*DeleteSchemaResponse) Reset ¶ added in v2.19.0
func (x *DeleteSchemaResponse) Reset()
func (*DeleteSchemaResponse) String ¶ added in v2.19.0
func (x *DeleteSchemaResponse) String() string
type GetSchemaCodeRequest ¶
type GetSchemaCodeRequest struct { // Deprecated: Do not use. BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"` Ref *v1.SchemaRef `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"` // (-- api-linter: core::0143::standardized-codes=disabled // aip.dev/not-precedent: language here is a programming language, not a human spoken language. --) Language string `protobuf:"bytes,3,opt,name=language,proto3" json:"language,omitempty"` // contains filtered or unexported fields }
func (*GetSchemaCodeRequest) Descriptor
deprecated
func (*GetSchemaCodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaCodeRequest.ProtoReflect.Descriptor instead.
func (*GetSchemaCodeRequest) GetBillingId
deprecated
func (x *GetSchemaCodeRequest) GetBillingId() string
Deprecated: Do not use.
func (*GetSchemaCodeRequest) GetLanguage ¶
func (x *GetSchemaCodeRequest) GetLanguage() string
func (*GetSchemaCodeRequest) GetRef ¶
func (x *GetSchemaCodeRequest) GetRef() *v1.SchemaRef
func (*GetSchemaCodeRequest) ProtoMessage ¶
func (*GetSchemaCodeRequest) ProtoMessage()
func (*GetSchemaCodeRequest) ProtoReflect ¶
func (x *GetSchemaCodeRequest) ProtoReflect() protoreflect.Message
func (*GetSchemaCodeRequest) Reset ¶
func (x *GetSchemaCodeRequest) Reset()
func (*GetSchemaCodeRequest) String ¶
func (x *GetSchemaCodeRequest) String() string
type GetSchemaCodeResponse ¶
type GetSchemaCodeResponse struct { Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"` DataSize int64 `protobuf:"varint,2,opt,name=data_size,json=dataSize,proto3" json:"data_size,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*GetSchemaCodeResponse) Descriptor
deprecated
func (*GetSchemaCodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaCodeResponse.ProtoReflect.Descriptor instead.
func (*GetSchemaCodeResponse) GetData ¶
func (x *GetSchemaCodeResponse) GetData() []byte
func (*GetSchemaCodeResponse) GetDataSize ¶
func (x *GetSchemaCodeResponse) GetDataSize() int64
func (*GetSchemaCodeResponse) GetFilename ¶
func (x *GetSchemaCodeResponse) GetFilename() string
func (*GetSchemaCodeResponse) ProtoMessage ¶
func (*GetSchemaCodeResponse) ProtoMessage()
func (*GetSchemaCodeResponse) ProtoReflect ¶
func (x *GetSchemaCodeResponse) ProtoReflect() protoreflect.Message
func (*GetSchemaCodeResponse) Reset ¶
func (x *GetSchemaCodeResponse) Reset()
func (*GetSchemaCodeResponse) String ¶
func (x *GetSchemaCodeResponse) String() string
type GetSchemaDefinitionRequest ¶ added in v2.28.0
type GetSchemaDefinitionRequest struct { ConfluentId int32 `protobuf:"varint,1,opt,name=confluent_id,json=confluentId,proto3" json:"confluent_id,omitempty"` ClusterRef *v1.KafkaClusterRef `protobuf:"bytes,2,opt,name=cluster_ref,json=clusterRef,proto3" json:"cluster_ref,omitempty"` // contains filtered or unexported fields }
func (*GetSchemaDefinitionRequest) Descriptor
deprecated
added in
v2.28.0
func (*GetSchemaDefinitionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaDefinitionRequest.ProtoReflect.Descriptor instead.
func (*GetSchemaDefinitionRequest) GetClusterRef ¶ added in v2.28.0
func (x *GetSchemaDefinitionRequest) GetClusterRef() *v1.KafkaClusterRef
func (*GetSchemaDefinitionRequest) GetConfluentId ¶ added in v2.28.0
func (x *GetSchemaDefinitionRequest) GetConfluentId() int32
func (*GetSchemaDefinitionRequest) ProtoMessage ¶ added in v2.28.0
func (*GetSchemaDefinitionRequest) ProtoMessage()
func (*GetSchemaDefinitionRequest) ProtoReflect ¶ added in v2.28.0
func (x *GetSchemaDefinitionRequest) ProtoReflect() protoreflect.Message
func (*GetSchemaDefinitionRequest) Reset ¶ added in v2.28.0
func (x *GetSchemaDefinitionRequest) Reset()
func (*GetSchemaDefinitionRequest) String ¶ added in v2.28.0
func (x *GetSchemaDefinitionRequest) String() string
type GetSchemaDefinitionResponse ¶ added in v2.28.0
type GetSchemaDefinitionResponse struct { Definition string `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"` // contains filtered or unexported fields }
func (*GetSchemaDefinitionResponse) Descriptor
deprecated
added in
v2.28.0
func (*GetSchemaDefinitionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaDefinitionResponse.ProtoReflect.Descriptor instead.
func (*GetSchemaDefinitionResponse) GetDefinition ¶ added in v2.28.0
func (x *GetSchemaDefinitionResponse) GetDefinition() string
func (*GetSchemaDefinitionResponse) ProtoMessage ¶ added in v2.28.0
func (*GetSchemaDefinitionResponse) ProtoMessage()
func (*GetSchemaDefinitionResponse) ProtoReflect ¶ added in v2.28.0
func (x *GetSchemaDefinitionResponse) ProtoReflect() protoreflect.Message
func (*GetSchemaDefinitionResponse) Reset ¶ added in v2.28.0
func (x *GetSchemaDefinitionResponse) Reset()
func (*GetSchemaDefinitionResponse) String ¶ added in v2.28.0
func (x *GetSchemaDefinitionResponse) String() string
type GetSchemaRequest ¶
type GetSchemaRequest struct { // Deprecated: Do not use. BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"` Ref *v1.SchemaRef `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"` ClusterRef *v1.KafkaClusterRef `protobuf:"bytes,3,opt,name=cluster_ref,json=clusterRef,proto3" json:"cluster_ref,omitempty"` // contains filtered or unexported fields }
func (*GetSchemaRequest) Descriptor
deprecated
func (*GetSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.
func (*GetSchemaRequest) GetBillingId
deprecated
func (x *GetSchemaRequest) GetBillingId() string
Deprecated: Do not use.
func (*GetSchemaRequest) GetClusterRef ¶
func (x *GetSchemaRequest) GetClusterRef() *v1.KafkaClusterRef
func (*GetSchemaRequest) GetRef ¶
func (x *GetSchemaRequest) GetRef() *v1.SchemaRef
func (*GetSchemaRequest) ProtoMessage ¶
func (*GetSchemaRequest) ProtoMessage()
func (*GetSchemaRequest) ProtoReflect ¶
func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message
func (*GetSchemaRequest) Reset ¶
func (x *GetSchemaRequest) Reset()
func (*GetSchemaRequest) String ¶
func (x *GetSchemaRequest) String() string
type GetSchemaResponse ¶
type GetSchemaResponse struct { Schema *v1.Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` ConfluentId int32 `protobuf:"varint,2,opt,name=confluent_id,json=confluentId,proto3" json:"confluent_id,omitempty"` Checksum string `protobuf:"bytes,3,opt,name=checksum,proto3" json:"checksum,omitempty"` // contains filtered or unexported fields }
func (*GetSchemaResponse) Descriptor
deprecated
func (*GetSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.
func (*GetSchemaResponse) GetChecksum ¶
func (x *GetSchemaResponse) GetChecksum() string
func (*GetSchemaResponse) GetConfluentId ¶
func (x *GetSchemaResponse) GetConfluentId() int32
func (*GetSchemaResponse) GetSchema ¶
func (x *GetSchemaResponse) GetSchema() *v1.Schema
func (*GetSchemaResponse) ProtoMessage ¶
func (*GetSchemaResponse) ProtoMessage()
func (*GetSchemaResponse) ProtoReflect ¶
func (x *GetSchemaResponse) ProtoReflect() protoreflect.Message
func (*GetSchemaResponse) Reset ¶
func (x *GetSchemaResponse) Reset()
func (*GetSchemaResponse) String ¶
func (x *GetSchemaResponse) String() string
type ListSchemasRequest ¶
type ListSchemasRequest struct { // The billing_id, used for authentication. // If absent, only public Schemas can be returned. If present, public and owned private Schemas can be returned. BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"` // Filter on a string to do a full-text search. Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` // Filter on a given handle. Handle string `protobuf:"bytes,3,opt,name=handle,proto3" json:"handle,omitempty"` // Filter on a given name. Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // Filter public/private Schemas. PublicPrivate v1.FilterPublicPrivate `` /* 154-byte string literal not displayed */ // Filter on the schema_type. SchemaType v1.SchemaType `` /* 136-byte string literal not displayed */ // Filter on labels. It is possible to skip the label value. // In that case, the filter only filters on the key. Labels []*v1.Label `protobuf:"bytes,7,rep,name=labels,proto3" json:"labels,omitempty"` // Filter on domains. Domains []string `protobuf:"bytes,8,rep,name=domains,proto3" json:"domains,omitempty"` // Filter on industries. Industries []string `protobuf:"bytes,9,rep,name=industries,proto3" json:"industries,omitempty"` // contains filtered or unexported fields }
List Schemas, with optional filters. All filters behave as AND conditions. OR is not possible.
func (*ListSchemasRequest) Descriptor
deprecated
func (*ListSchemasRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSchemasRequest.ProtoReflect.Descriptor instead.
func (*ListSchemasRequest) GetBillingId ¶
func (x *ListSchemasRequest) GetBillingId() string
func (*ListSchemasRequest) GetDomains ¶
func (x *ListSchemasRequest) GetDomains() []string
func (*ListSchemasRequest) GetFilter ¶
func (x *ListSchemasRequest) GetFilter() string
func (*ListSchemasRequest) GetHandle ¶
func (x *ListSchemasRequest) GetHandle() string
func (*ListSchemasRequest) GetIndustries ¶
func (x *ListSchemasRequest) GetIndustries() []string
func (*ListSchemasRequest) GetLabels ¶
func (x *ListSchemasRequest) GetLabels() []*v1.Label
func (*ListSchemasRequest) GetName ¶
func (x *ListSchemasRequest) GetName() string
func (*ListSchemasRequest) GetPublicPrivate ¶
func (x *ListSchemasRequest) GetPublicPrivate() v1.FilterPublicPrivate
func (*ListSchemasRequest) GetSchemaType ¶
func (x *ListSchemasRequest) GetSchemaType() v1.SchemaType
func (*ListSchemasRequest) ProtoMessage ¶
func (*ListSchemasRequest) ProtoMessage()
func (*ListSchemasRequest) ProtoReflect ¶
func (x *ListSchemasRequest) ProtoReflect() protoreflect.Message
func (*ListSchemasRequest) Reset ¶
func (x *ListSchemasRequest) Reset()
func (*ListSchemasRequest) String ¶
func (x *ListSchemasRequest) String() string
type ListSchemasResponse ¶
type ListSchemasResponse struct { Schemas []*v1.Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"` // contains filtered or unexported fields }
(-- api-linter: core::0158::response-plural-first-field=disabled
aip.dev/not-precedent: Somehow this rule is not correctly checked here. --)
func (*ListSchemasResponse) Descriptor
deprecated
func (*ListSchemasResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSchemasResponse.ProtoReflect.Descriptor instead.
func (*ListSchemasResponse) GetSchemas ¶
func (x *ListSchemasResponse) GetSchemas() []*v1.Schema
func (*ListSchemasResponse) ProtoMessage ¶
func (*ListSchemasResponse) ProtoMessage()
func (*ListSchemasResponse) ProtoReflect ¶
func (x *ListSchemasResponse) ProtoReflect() protoreflect.Message
func (*ListSchemasResponse) Reset ¶
func (x *ListSchemasResponse) Reset()
func (*ListSchemasResponse) String ¶
func (x *ListSchemasResponse) String() string
type SchemasServiceClient ¶
type SchemasServiceClient interface { ListSchemas(ctx context.Context, in *ListSchemasRequest, opts ...grpc.CallOption) (*ListSchemasResponse, error) GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error) CreateSchema(ctx context.Context, in *CreateSchemaRequest, opts ...grpc.CallOption) (*CreateSchemaResponse, error) UpdateSchema(ctx context.Context, in *UpdateSchemaRequest, opts ...grpc.CallOption) (*UpdateSchemaResponse, error) GetSchemaCode(ctx context.Context, in *GetSchemaCodeRequest, opts ...grpc.CallOption) (*GetSchemaCodeResponse, error) ActivateSchema(ctx context.Context, in *ActivateSchemaRequest, opts ...grpc.CallOption) (*ActivateSchemaResponse, error) DeleteSchema(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*DeleteSchemaResponse, error) ArchiveSchema(ctx context.Context, in *ArchiveSchemaRequest, opts ...grpc.CallOption) (*ArchiveSchemaResponse, error) GetSchemaDefinition(ctx context.Context, in *GetSchemaDefinitionRequest, opts ...grpc.CallOption) (*GetSchemaDefinitionResponse, error) }
SchemasServiceClient is the client API for SchemasService 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 NewSchemasServiceClient ¶
func NewSchemasServiceClient(cc grpc.ClientConnInterface) SchemasServiceClient
type SchemasServiceServer ¶
type SchemasServiceServer interface { ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error) GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error) CreateSchema(context.Context, *CreateSchemaRequest) (*CreateSchemaResponse, error) UpdateSchema(context.Context, *UpdateSchemaRequest) (*UpdateSchemaResponse, error) GetSchemaCode(context.Context, *GetSchemaCodeRequest) (*GetSchemaCodeResponse, error) ActivateSchema(context.Context, *ActivateSchemaRequest) (*ActivateSchemaResponse, error) DeleteSchema(context.Context, *DeleteSchemaRequest) (*DeleteSchemaResponse, error) ArchiveSchema(context.Context, *ArchiveSchemaRequest) (*ArchiveSchemaResponse, error) GetSchemaDefinition(context.Context, *GetSchemaDefinitionRequest) (*GetSchemaDefinitionResponse, error) // contains filtered or unexported methods }
SchemasServiceServer is the server API for SchemasService service. All implementations must embed UnimplementedSchemasServiceServer for forward compatibility
type UnimplementedSchemasServiceServer ¶
type UnimplementedSchemasServiceServer struct { }
UnimplementedSchemasServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedSchemasServiceServer) ActivateSchema ¶ added in v2.19.0
func (UnimplementedSchemasServiceServer) ActivateSchema(context.Context, *ActivateSchemaRequest) (*ActivateSchemaResponse, error)
func (UnimplementedSchemasServiceServer) ArchiveSchema ¶ added in v2.19.0
func (UnimplementedSchemasServiceServer) ArchiveSchema(context.Context, *ArchiveSchemaRequest) (*ArchiveSchemaResponse, error)
func (UnimplementedSchemasServiceServer) CreateSchema ¶
func (UnimplementedSchemasServiceServer) CreateSchema(context.Context, *CreateSchemaRequest) (*CreateSchemaResponse, error)
func (UnimplementedSchemasServiceServer) DeleteSchema ¶ added in v2.19.0
func (UnimplementedSchemasServiceServer) DeleteSchema(context.Context, *DeleteSchemaRequest) (*DeleteSchemaResponse, error)
func (UnimplementedSchemasServiceServer) GetSchema ¶
func (UnimplementedSchemasServiceServer) GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
func (UnimplementedSchemasServiceServer) GetSchemaCode ¶
func (UnimplementedSchemasServiceServer) GetSchemaCode(context.Context, *GetSchemaCodeRequest) (*GetSchemaCodeResponse, error)
func (UnimplementedSchemasServiceServer) GetSchemaDefinition ¶ added in v2.28.0
func (UnimplementedSchemasServiceServer) GetSchemaDefinition(context.Context, *GetSchemaDefinitionRequest) (*GetSchemaDefinitionResponse, error)
func (UnimplementedSchemasServiceServer) ListSchemas ¶
func (UnimplementedSchemasServiceServer) ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error)
func (UnimplementedSchemasServiceServer) UpdateSchema ¶
func (UnimplementedSchemasServiceServer) UpdateSchema(context.Context, *UpdateSchemaRequest) (*UpdateSchemaResponse, error)
type UnsafeSchemasServiceServer ¶
type UnsafeSchemasServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSchemasServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SchemasServiceServer will result in compilation errors.
type UpdateSchemaRequest ¶
type UpdateSchemaRequest struct { // Deprecated: Do not use. BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"` Schema *v1.Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"` Checksum string `protobuf:"bytes,3,opt,name=checksum,proto3" json:"checksum,omitempty"` // The fields to update. UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,4,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` ProjectId string `protobuf:"bytes,5,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // contains filtered or unexported fields }
func (*UpdateSchemaRequest) Descriptor
deprecated
func (*UpdateSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSchemaRequest.ProtoReflect.Descriptor instead.
func (*UpdateSchemaRequest) GetBillingId
deprecated
func (x *UpdateSchemaRequest) GetBillingId() string
Deprecated: Do not use.
func (*UpdateSchemaRequest) GetChecksum ¶
func (x *UpdateSchemaRequest) GetChecksum() string
func (*UpdateSchemaRequest) GetProjectId ¶ added in v2.38.0
func (x *UpdateSchemaRequest) GetProjectId() string
func (*UpdateSchemaRequest) GetSchema ¶
func (x *UpdateSchemaRequest) GetSchema() *v1.Schema
func (*UpdateSchemaRequest) GetUpdateMask ¶
func (x *UpdateSchemaRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateSchemaRequest) ProtoMessage ¶
func (*UpdateSchemaRequest) ProtoMessage()
func (*UpdateSchemaRequest) ProtoReflect ¶
func (x *UpdateSchemaRequest) ProtoReflect() protoreflect.Message
func (*UpdateSchemaRequest) Reset ¶
func (x *UpdateSchemaRequest) Reset()
func (*UpdateSchemaRequest) String ¶
func (x *UpdateSchemaRequest) String() string
type UpdateSchemaResponse ¶
type UpdateSchemaResponse struct { Schema *v1.Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` Checksum string `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"` // contains filtered or unexported fields }
func (*UpdateSchemaResponse) Descriptor
deprecated
func (*UpdateSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSchemaResponse.ProtoReflect.Descriptor instead.
func (*UpdateSchemaResponse) GetChecksum ¶
func (x *UpdateSchemaResponse) GetChecksum() string
func (*UpdateSchemaResponse) GetSchema ¶
func (x *UpdateSchemaResponse) GetSchema() *v1.Schema
func (*UpdateSchemaResponse) ProtoMessage ¶
func (*UpdateSchemaResponse) ProtoMessage()
func (*UpdateSchemaResponse) ProtoReflect ¶
func (x *UpdateSchemaResponse) ProtoReflect() protoreflect.Message
func (*UpdateSchemaResponse) Reset ¶
func (x *UpdateSchemaResponse) Reset()
func (*UpdateSchemaResponse) String ¶
func (x *UpdateSchemaResponse) String() string