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 ¶
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
func (*ActivateSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActivateSchemaRequest.ProtoReflect.Descriptor instead.
func (*ActivateSchemaRequest) GetBillingId
deprecated
func (x *ActivateSchemaRequest) GetBillingId() string
Deprecated: Do not use.
func (*ActivateSchemaRequest) GetProjectId ¶
func (x *ActivateSchemaRequest) GetProjectId() string
func (*ActivateSchemaRequest) GetSchemaRef ¶
func (x *ActivateSchemaRequest) GetSchemaRef() *v1.SchemaRef
func (*ActivateSchemaRequest) ProtoMessage ¶
func (*ActivateSchemaRequest) ProtoMessage()
func (*ActivateSchemaRequest) ProtoReflect ¶
func (x *ActivateSchemaRequest) ProtoReflect() protoreflect.Message
func (*ActivateSchemaRequest) Reset ¶
func (x *ActivateSchemaRequest) Reset()
func (*ActivateSchemaRequest) String ¶
func (x *ActivateSchemaRequest) String() string
type ActivateSchemaResponse ¶
type ActivateSchemaResponse struct {
// contains filtered or unexported fields
}
func (*ActivateSchemaResponse) Descriptor
deprecated
func (*ActivateSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use ActivateSchemaResponse.ProtoReflect.Descriptor instead.
func (*ActivateSchemaResponse) ProtoMessage ¶
func (*ActivateSchemaResponse) ProtoMessage()
func (*ActivateSchemaResponse) ProtoReflect ¶
func (x *ActivateSchemaResponse) ProtoReflect() protoreflect.Message
func (*ActivateSchemaResponse) Reset ¶
func (x *ActivateSchemaResponse) Reset()
func (*ActivateSchemaResponse) String ¶
func (x *ActivateSchemaResponse) String() string
type ArchiveSchemaRequest ¶
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
func (*ArchiveSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use ArchiveSchemaRequest.ProtoReflect.Descriptor instead.
func (*ArchiveSchemaRequest) GetBillingId
deprecated
func (x *ArchiveSchemaRequest) GetBillingId() string
Deprecated: Do not use.
func (*ArchiveSchemaRequest) GetProjectId ¶
func (x *ArchiveSchemaRequest) GetProjectId() string
func (*ArchiveSchemaRequest) GetSchemaRef ¶
func (x *ArchiveSchemaRequest) GetSchemaRef() *v1.SchemaRef
func (*ArchiveSchemaRequest) ProtoMessage ¶
func (*ArchiveSchemaRequest) ProtoMessage()
func (*ArchiveSchemaRequest) ProtoReflect ¶
func (x *ArchiveSchemaRequest) ProtoReflect() protoreflect.Message
func (*ArchiveSchemaRequest) Reset ¶
func (x *ArchiveSchemaRequest) Reset()
func (*ArchiveSchemaRequest) String ¶
func (x *ArchiveSchemaRequest) String() string
type ArchiveSchemaResponse ¶
type ArchiveSchemaResponse struct {
// contains filtered or unexported fields
}
func (*ArchiveSchemaResponse) Descriptor
deprecated
func (*ArchiveSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use ArchiveSchemaResponse.ProtoReflect.Descriptor instead.
func (*ArchiveSchemaResponse) ProtoMessage ¶
func (*ArchiveSchemaResponse) ProtoMessage()
func (*ArchiveSchemaResponse) ProtoReflect ¶
func (x *ArchiveSchemaResponse) ProtoReflect() protoreflect.Message
func (*ArchiveSchemaResponse) Reset ¶
func (x *ArchiveSchemaResponse) Reset()
func (*ArchiveSchemaResponse) String ¶
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 ¶
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 ¶
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
func (*DeleteSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSchemaRequest.ProtoReflect.Descriptor instead.
func (*DeleteSchemaRequest) GetBillingId
deprecated
func (x *DeleteSchemaRequest) GetBillingId() string
Deprecated: Do not use.
func (*DeleteSchemaRequest) GetProjectId ¶
func (x *DeleteSchemaRequest) GetProjectId() string
func (*DeleteSchemaRequest) GetSchemaRef ¶
func (x *DeleteSchemaRequest) GetSchemaRef() *v1.SchemaRef
func (*DeleteSchemaRequest) ProtoMessage ¶
func (*DeleteSchemaRequest) ProtoMessage()
func (*DeleteSchemaRequest) ProtoReflect ¶
func (x *DeleteSchemaRequest) ProtoReflect() protoreflect.Message
func (*DeleteSchemaRequest) Reset ¶
func (x *DeleteSchemaRequest) Reset()
func (*DeleteSchemaRequest) String ¶
func (x *DeleteSchemaRequest) String() string
type DeleteSchemaResponse ¶
type DeleteSchemaResponse struct {
// contains filtered or unexported fields
}
func (*DeleteSchemaResponse) Descriptor
deprecated
func (*DeleteSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSchemaResponse.ProtoReflect.Descriptor instead.
func (*DeleteSchemaResponse) ProtoMessage ¶
func (*DeleteSchemaResponse) ProtoMessage()
func (*DeleteSchemaResponse) ProtoReflect ¶
func (x *DeleteSchemaResponse) ProtoReflect() protoreflect.Message
func (*DeleteSchemaResponse) Reset ¶
func (x *DeleteSchemaResponse) Reset()
func (*DeleteSchemaResponse) String ¶
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 ¶
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
func (*GetSchemaDefinitionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaDefinitionRequest.ProtoReflect.Descriptor instead.
func (*GetSchemaDefinitionRequest) GetClusterRef ¶
func (x *GetSchemaDefinitionRequest) GetClusterRef() *v1.KafkaClusterRef
func (*GetSchemaDefinitionRequest) GetConfluentId ¶
func (x *GetSchemaDefinitionRequest) GetConfluentId() int32
func (*GetSchemaDefinitionRequest) ProtoMessage ¶
func (*GetSchemaDefinitionRequest) ProtoMessage()
func (*GetSchemaDefinitionRequest) ProtoReflect ¶
func (x *GetSchemaDefinitionRequest) ProtoReflect() protoreflect.Message
func (*GetSchemaDefinitionRequest) Reset ¶
func (x *GetSchemaDefinitionRequest) Reset()
func (*GetSchemaDefinitionRequest) String ¶
func (x *GetSchemaDefinitionRequest) String() string
type GetSchemaDefinitionResponse ¶
type GetSchemaDefinitionResponse struct { Definition string `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"` // contains filtered or unexported fields }
func (*GetSchemaDefinitionResponse) Descriptor
deprecated
func (*GetSchemaDefinitionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaDefinitionResponse.ProtoReflect.Descriptor instead.
func (*GetSchemaDefinitionResponse) GetDefinition ¶
func (x *GetSchemaDefinitionResponse) GetDefinition() string
func (*GetSchemaDefinitionResponse) ProtoMessage ¶
func (*GetSchemaDefinitionResponse) ProtoMessage()
func (*GetSchemaDefinitionResponse) ProtoReflect ¶
func (x *GetSchemaDefinitionResponse) ProtoReflect() protoreflect.Message
func (*GetSchemaDefinitionResponse) Reset ¶
func (x *GetSchemaDefinitionResponse) Reset()
func (*GetSchemaDefinitionResponse) String ¶
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) }
SchemasServiceServer is the server API for SchemasService service. All implementations should embed UnimplementedSchemasServiceServer for forward compatibility
type UnimplementedSchemasServiceServer ¶
type UnimplementedSchemasServiceServer struct { }
UnimplementedSchemasServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedSchemasServiceServer) ActivateSchema ¶
func (UnimplementedSchemasServiceServer) ActivateSchema(context.Context, *ActivateSchemaRequest) (*ActivateSchemaResponse, error)
func (UnimplementedSchemasServiceServer) ArchiveSchema ¶
func (UnimplementedSchemasServiceServer) ArchiveSchema(context.Context, *ArchiveSchemaRequest) (*ArchiveSchemaResponse, error)
func (UnimplementedSchemasServiceServer) CreateSchema ¶
func (UnimplementedSchemasServiceServer) CreateSchema(context.Context, *CreateSchemaRequest) (*CreateSchemaResponse, error)
func (UnimplementedSchemasServiceServer) DeleteSchema ¶
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 ¶
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 ¶
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