schemaregistrypb

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 13, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ManagedSchemaRegistry_GetSchemaRegistry_FullMethodName      = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/GetSchemaRegistry"
	ManagedSchemaRegistry_ListSchemaRegistries_FullMethodName   = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/ListSchemaRegistries"
	ManagedSchemaRegistry_CreateSchemaRegistry_FullMethodName   = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/CreateSchemaRegistry"
	ManagedSchemaRegistry_DeleteSchemaRegistry_FullMethodName   = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/DeleteSchemaRegistry"
	ManagedSchemaRegistry_GetContext_FullMethodName             = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/GetContext"
	ManagedSchemaRegistry_ListContexts_FullMethodName           = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/ListContexts"
	ManagedSchemaRegistry_GetSchema_FullMethodName              = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/GetSchema"
	ManagedSchemaRegistry_GetRawSchema_FullMethodName           = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/GetRawSchema"
	ManagedSchemaRegistry_ListSchemaVersions_FullMethodName     = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/ListSchemaVersions"
	ManagedSchemaRegistry_ListSchemaTypes_FullMethodName        = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/ListSchemaTypes"
	ManagedSchemaRegistry_ListSubjects_FullMethodName           = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/ListSubjects"
	ManagedSchemaRegistry_ListSubjectsBySchemaId_FullMethodName = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/ListSubjectsBySchemaId"
	ManagedSchemaRegistry_DeleteSubject_FullMethodName          = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/DeleteSubject"
	ManagedSchemaRegistry_LookupVersion_FullMethodName          = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/LookupVersion"
	ManagedSchemaRegistry_GetVersion_FullMethodName             = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/GetVersion"
	ManagedSchemaRegistry_GetRawSchemaVersion_FullMethodName    = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/GetRawSchemaVersion"
	ManagedSchemaRegistry_ListVersions_FullMethodName           = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/ListVersions"
	ManagedSchemaRegistry_CreateVersion_FullMethodName          = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/CreateVersion"
	ManagedSchemaRegistry_DeleteVersion_FullMethodName          = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/DeleteVersion"
	ManagedSchemaRegistry_ListReferencedSchemas_FullMethodName  = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/ListReferencedSchemas"
	ManagedSchemaRegistry_CheckCompatibility_FullMethodName     = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/CheckCompatibility"
	ManagedSchemaRegistry_GetSchemaConfig_FullMethodName        = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/GetSchemaConfig"
	ManagedSchemaRegistry_UpdateSchemaConfig_FullMethodName     = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/UpdateSchemaConfig"
	ManagedSchemaRegistry_DeleteSchemaConfig_FullMethodName     = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/DeleteSchemaConfig"
	ManagedSchemaRegistry_GetSchemaMode_FullMethodName          = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/GetSchemaMode"
	ManagedSchemaRegistry_UpdateSchemaMode_FullMethodName       = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/UpdateSchemaMode"
	ManagedSchemaRegistry_DeleteSchemaMode_FullMethodName       = "/google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry/DeleteSchemaMode"
)

Variables

View Source 
var (
	Schema_SchemaType_name = map[int32]string{
		0: "SCHEMA_TYPE_UNSPECIFIED",
		1: "AVRO",
		2: "JSON",
		3: "PROTOBUF",
	}
	Schema_SchemaType_value = map[string]int32{
		"SCHEMA_TYPE_UNSPECIFIED": 0,
		"AVRO":                    1,
		"JSON":                    2,
		"PROTOBUF":                3,
	}
)

Enum value maps for Schema_SchemaType.

View Source 
var (
	SchemaConfig_CompatibilityType_name = map[int32]string{
		0: "NONE",
		1: "BACKWARD",
		2: "BACKWARD_TRANSITIVE",
		3: "FORWARD",
		4: "FORWARD_TRANSITIVE",
		5: "FULL",
		6: "FULL_TRANSITIVE",
	}
	SchemaConfig_CompatibilityType_value = map[string]int32{
		"NONE":                0,
		"BACKWARD":            1,
		"BACKWARD_TRANSITIVE": 2,
		"FORWARD":             3,
		"FORWARD_TRANSITIVE":  4,
		"FULL":                5,
		"FULL_TRANSITIVE":     6,
	}
)

Enum value maps for SchemaConfig_CompatibilityType.

View Source 
var (
	SchemaMode_ModeType_name = map[int32]string{
		0: "NONE",
		1: "READONLY",
		2: "READWRITE",
		3: "IMPORT",
	}
	SchemaMode_ModeType_value = map[string]int32{
		"NONE":      0,
		"READONLY":  1,
		"READWRITE": 2,
		"IMPORT":    3,
	}
)

Enum value maps for SchemaMode_ModeType.

View Source 
var File_google_cloud_managedkafka_schemaregistry_v1_schema_registry_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_managedkafka_schemaregistry_v1_schema_registry_resources_proto protoreflect.FileDescriptor
View Source 
var ManagedSchemaRegistry_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.cloud.managedkafka.schemaregistry.v1.ManagedSchemaRegistry",
	HandlerType: (*ManagedSchemaRegistryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSchemaRegistry",
			Handler:    _ManagedSchemaRegistry_GetSchemaRegistry_Handler,
		},
		{
			MethodName: "ListSchemaRegistries",
			Handler:    _ManagedSchemaRegistry_ListSchemaRegistries_Handler,
		},
		{
			MethodName: "CreateSchemaRegistry",
			Handler:    _ManagedSchemaRegistry_CreateSchemaRegistry_Handler,
		},
		{
			MethodName: "DeleteSchemaRegistry",
			Handler:    _ManagedSchemaRegistry_DeleteSchemaRegistry_Handler,
		},
		{
			MethodName: "GetContext",
			Handler:    _ManagedSchemaRegistry_GetContext_Handler,
		},
		{
			MethodName: "ListContexts",
			Handler:    _ManagedSchemaRegistry_ListContexts_Handler,
		},
		{
			MethodName: "GetSchema",
			Handler:    _ManagedSchemaRegistry_GetSchema_Handler,
		},
		{
			MethodName: "GetRawSchema",
			Handler:    _ManagedSchemaRegistry_GetRawSchema_Handler,
		},
		{
			MethodName: "ListSchemaVersions",
			Handler:    _ManagedSchemaRegistry_ListSchemaVersions_Handler,
		},
		{
			MethodName: "ListSchemaTypes",
			Handler:    _ManagedSchemaRegistry_ListSchemaTypes_Handler,
		},
		{
			MethodName: "ListSubjects",
			Handler:    _ManagedSchemaRegistry_ListSubjects_Handler,
		},
		{
			MethodName: "ListSubjectsBySchemaId",
			Handler:    _ManagedSchemaRegistry_ListSubjectsBySchemaId_Handler,
		},
		{
			MethodName: "DeleteSubject",
			Handler:    _ManagedSchemaRegistry_DeleteSubject_Handler,
		},
		{
			MethodName: "LookupVersion",
			Handler:    _ManagedSchemaRegistry_LookupVersion_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _ManagedSchemaRegistry_GetVersion_Handler,
		},
		{
			MethodName: "GetRawSchemaVersion",
			Handler:    _ManagedSchemaRegistry_GetRawSchemaVersion_Handler,
		},
		{
			MethodName: "ListVersions",
			Handler:    _ManagedSchemaRegistry_ListVersions_Handler,
		},
		{
			MethodName: "CreateVersion",
			Handler:    _ManagedSchemaRegistry_CreateVersion_Handler,
		},
		{
			MethodName: "DeleteVersion",
			Handler:    _ManagedSchemaRegistry_DeleteVersion_Handler,
		},
		{
			MethodName: "ListReferencedSchemas",
			Handler:    _ManagedSchemaRegistry_ListReferencedSchemas_Handler,
		},
		{
			MethodName: "CheckCompatibility",
			Handler:    _ManagedSchemaRegistry_CheckCompatibility_Handler,
		},
		{
			MethodName: "GetSchemaConfig",
			Handler:    _ManagedSchemaRegistry_GetSchemaConfig_Handler,
		},
		{
			MethodName: "UpdateSchemaConfig",
			Handler:    _ManagedSchemaRegistry_UpdateSchemaConfig_Handler,
		},
		{
			MethodName: "DeleteSchemaConfig",
			Handler:    _ManagedSchemaRegistry_DeleteSchemaConfig_Handler,
		},
		{
			MethodName: "GetSchemaMode",
			Handler:    _ManagedSchemaRegistry_GetSchemaMode_Handler,
		},
		{
			MethodName: "UpdateSchemaMode",
			Handler:    _ManagedSchemaRegistry_UpdateSchemaMode_Handler,
		},
		{
			MethodName: "DeleteSchemaMode",
			Handler:    _ManagedSchemaRegistry_DeleteSchemaMode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "google/cloud/managedkafka/schemaregistry/v1/schema_registry.proto",
}

ManagedSchemaRegistry_ServiceDesc is the grpc.ServiceDesc for ManagedSchemaRegistry service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterManagedSchemaRegistryServer 

func RegisterManagedSchemaRegistryServer(s grpc.ServiceRegistrar, srv ManagedSchemaRegistryServer)

Types

type CheckCompatibilityRequest 

type CheckCompatibilityRequest struct {

	// Required. The name of the resource to check compatibility for. The format
	// is either of following:
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/compatibility/subjects/*/versions: Check compatibility with one or
	//     more versions of the specified subject.
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/compatibility/subjects/{subject}/versions/{version}: Check
	//     compatibility with a specific version of the subject.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. The schema type of the schema.
	SchemaType *Schema_SchemaType `` /* 165-byte string literal not displayed */
	// Required. The schema payload
	Schema string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// Optional. The schema references used by the schema.
	References []*Schema_SchemaReference `protobuf:"bytes,4,rep,name=references,proto3" json:"references,omitempty"`
	// Optional. If true, the response will contain the compatibility check result
	// with reasons for failed checks. The default is false.
	Verbose *bool `protobuf:"varint,5,opt,name=verbose,proto3,oneof" json:"verbose,omitempty"`
	// contains filtered or unexported fields
}

Request for CheckCompatibility.

func (*CheckCompatibilityRequest) Descriptor deprecated 

func (*CheckCompatibilityRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckCompatibilityRequest.ProtoReflect.Descriptor instead.

func (*CheckCompatibilityRequest) GetName 

func (x *CheckCompatibilityRequest) GetName() string

func (*CheckCompatibilityRequest) GetReferences 

func (x *CheckCompatibilityRequest) GetReferences() []*Schema_SchemaReference

func (*CheckCompatibilityRequest) GetSchema 

func (x *CheckCompatibilityRequest) GetSchema() string

func (*CheckCompatibilityRequest) GetSchemaType 

func (x *CheckCompatibilityRequest) GetSchemaType() Schema_SchemaType

func (*CheckCompatibilityRequest) GetVerbose 

func (x *CheckCompatibilityRequest) GetVerbose() bool

func (*CheckCompatibilityRequest) ProtoMessage 

func (*CheckCompatibilityRequest) ProtoMessage()

func (*CheckCompatibilityRequest) ProtoReflect 

func (x *CheckCompatibilityRequest) ProtoReflect() protoreflect.Message

func (*CheckCompatibilityRequest) Reset 

func (x *CheckCompatibilityRequest) Reset()

func (*CheckCompatibilityRequest) String 

func (x *CheckCompatibilityRequest) String() string

type CheckCompatibilityResponse 

type CheckCompatibilityResponse struct {

	// The compatibility check result. If true, the schema is compatible with the
	// resource.
	IsCompatible bool `protobuf:"varint,1,opt,name=is_compatible,proto3" json:"is_compatible,omitempty"`
	// Failure reasons if verbose = true.
	Messages []string `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

Response for CheckCompatibility.

func (*CheckCompatibilityResponse) Descriptor deprecated 

func (*CheckCompatibilityResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckCompatibilityResponse.ProtoReflect.Descriptor instead.

func (*CheckCompatibilityResponse) GetIsCompatible 

func (x *CheckCompatibilityResponse) GetIsCompatible() bool

func (*CheckCompatibilityResponse) GetMessages 

func (x *CheckCompatibilityResponse) GetMessages() []string

func (*CheckCompatibilityResponse) ProtoMessage 

func (*CheckCompatibilityResponse) ProtoMessage()

func (*CheckCompatibilityResponse) ProtoReflect 

func (x *CheckCompatibilityResponse) ProtoReflect() protoreflect.Message

func (*CheckCompatibilityResponse) Reset 

func (x *CheckCompatibilityResponse) Reset()

func (*CheckCompatibilityResponse) String 

func (x *CheckCompatibilityResponse) String() string

type Context 

type Context struct {

	// Identifier. The name of the context. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}`
	// The context name {context} can contain the following:
	// * Up to 255 characters.
	// * Allowed characters: letters (uppercase or lowercase), numbers, and the
	// following special characters: `.`, `-`, `_`, `+`, `%`, and `~`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. The subjects of the context.
	Subjects []string `protobuf:"bytes,2,rep,name=subjects,proto3" json:"subjects,omitempty"`
	// contains filtered or unexported fields
}

Context represents an independent schema grouping in a schema registry instance.

func (*Context) Descriptor deprecated 

func (*Context) Descriptor() ([]byte, []int)

Deprecated: Use Context.ProtoReflect.Descriptor instead.

func (*Context) GetName 

func (x *Context) GetName() string

func (*Context) GetSubjects 

func (x *Context) GetSubjects() []string

func (*Context) ProtoMessage 

func (*Context) ProtoMessage()

func (*Context) ProtoReflect 

func (x *Context) ProtoReflect() protoreflect.Message

func (*Context) Reset 

func (x *Context) Reset()

func (*Context) String 

func (x *Context) String() string

type CreateSchemaRegistryRequest 

type CreateSchemaRegistryRequest struct {

	// Required. The parent whose schema registry instance is to be created.
	// Structured like: `projects/{project}/locations/{location}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The schema registry instance ID to use for this schema registry.
	// The ID must contain only letters (a-z, A-Z), numbers (0-9), and underscores
	// (-). The maximum length is 63 characters.
	// The ID must not start with a number.
	SchemaRegistryId string `protobuf:"bytes,2,opt,name=schema_registry_id,json=schemaRegistryId,proto3" json:"schema_registry_id,omitempty"`
	// Required. The schema registry instance to create.
	// The name field is ignored.
	SchemaRegistry *SchemaRegistry `protobuf:"bytes,3,opt,name=schema_registry,json=schemaRegistry,proto3" json:"schema_registry,omitempty"`
	// contains filtered or unexported fields
}

Request to create a schema registry instance.

func (*CreateSchemaRegistryRequest) Descriptor deprecated 

func (*CreateSchemaRegistryRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateSchemaRegistryRequest.ProtoReflect.Descriptor instead.

func (*CreateSchemaRegistryRequest) GetParent 

func (x *CreateSchemaRegistryRequest) GetParent() string

func (*CreateSchemaRegistryRequest) GetSchemaRegistry 

func (x *CreateSchemaRegistryRequest) GetSchemaRegistry() *SchemaRegistry

func (*CreateSchemaRegistryRequest) GetSchemaRegistryId 

func (x *CreateSchemaRegistryRequest) GetSchemaRegistryId() string

func (*CreateSchemaRegistryRequest) ProtoMessage 

func (*CreateSchemaRegistryRequest) ProtoMessage()

func (*CreateSchemaRegistryRequest) ProtoReflect 

func (x *CreateSchemaRegistryRequest) ProtoReflect() protoreflect.Message

func (*CreateSchemaRegistryRequest) Reset 

func (x *CreateSchemaRegistryRequest) Reset()

func (*CreateSchemaRegistryRequest) String 

func (x *CreateSchemaRegistryRequest) String() string

type CreateVersionRequest 

type CreateVersionRequest struct {

	// Required. The subject to create the version for. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The version to create. It is optional. If not specified, the
	// version will be created with the max version ID of the subject increased
	// by 1. If the version ID is specified, it will be used as the new version ID
	// and must not be used by an existing version of the subject.
	Version *int32 `protobuf:"varint,2,opt,name=version,proto3,oneof" json:"version,omitempty"`
	// Optional. The schema ID of the schema. If not specified, the schema ID will
	// be generated by the server. If the schema ID is specified, it must not be
	// used by an existing schema that is different from the schema to be created.
	Id *int32 `protobuf:"varint,3,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// Optional. The type of the schema. It is optional. If not specified, the
	// schema type will be AVRO.
	SchemaType *Schema_SchemaType `` /* 165-byte string literal not displayed */
	// Required. The schema payload
	Schema string `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	// Optional. The schema references used by the schema.
	References []*Schema_SchemaReference `protobuf:"bytes,6,rep,name=references,proto3" json:"references,omitempty"`
	// Optional. If true, the schema will be normalized before being stored. The
	// default is false.
	Normalize *bool `protobuf:"varint,7,opt,name=normalize,proto3,oneof" json:"normalize,omitempty"`
	// contains filtered or unexported fields
}

Request for CreateVersion.

func (*CreateVersionRequest) Descriptor deprecated 

func (*CreateVersionRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateVersionRequest.ProtoReflect.Descriptor instead.

func (*CreateVersionRequest) GetId 

func (x *CreateVersionRequest) GetId() int32

func (*CreateVersionRequest) GetNormalize 

func (x *CreateVersionRequest) GetNormalize() bool

func (*CreateVersionRequest) GetParent 

func (x *CreateVersionRequest) GetParent() string

func (*CreateVersionRequest) GetReferences 

func (x *CreateVersionRequest) GetReferences() []*Schema_SchemaReference

func (*CreateVersionRequest) GetSchema 

func (x *CreateVersionRequest) GetSchema() string

func (*CreateVersionRequest) GetSchemaType 

func (x *CreateVersionRequest) GetSchemaType() Schema_SchemaType

func (*CreateVersionRequest) GetVersion 

func (x *CreateVersionRequest) GetVersion() int32

func (*CreateVersionRequest) ProtoMessage 

func (*CreateVersionRequest) ProtoMessage()

func (*CreateVersionRequest) ProtoReflect 

func (x *CreateVersionRequest) ProtoReflect() protoreflect.Message

func (*CreateVersionRequest) Reset 

func (x *CreateVersionRequest) Reset()

func (*CreateVersionRequest) String 

func (x *CreateVersionRequest) String() string

type CreateVersionResponse 

type CreateVersionResponse struct {

	// The unique identifier of the schema created.
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Response for CreateVersion.

func (*CreateVersionResponse) Descriptor deprecated 

func (*CreateVersionResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateVersionResponse.ProtoReflect.Descriptor instead.

func (*CreateVersionResponse) GetId 

func (x *CreateVersionResponse) GetId() int32

func (*CreateVersionResponse) ProtoMessage 

func (*CreateVersionResponse) ProtoMessage()

func (*CreateVersionResponse) ProtoReflect 

func (x *CreateVersionResponse) ProtoReflect() protoreflect.Message

func (*CreateVersionResponse) Reset 

func (x *CreateVersionResponse) Reset()

func (*CreateVersionResponse) String 

func (x *CreateVersionResponse) String() string

type DeleteSchemaConfigRequest 

type DeleteSchemaConfigRequest struct {

	// Required. The resource name of subject to delete the config for. The format
	// is
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config/{subject}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for deleting schema config.

func (*DeleteSchemaConfigRequest) Descriptor deprecated 

func (*DeleteSchemaConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteSchemaConfigRequest.ProtoReflect.Descriptor instead.

func (*DeleteSchemaConfigRequest) GetName 

func (x *DeleteSchemaConfigRequest) GetName() string

func (*DeleteSchemaConfigRequest) ProtoMessage 

func (*DeleteSchemaConfigRequest) ProtoMessage()

func (*DeleteSchemaConfigRequest) ProtoReflect 

func (x *DeleteSchemaConfigRequest) ProtoReflect() protoreflect.Message

func (*DeleteSchemaConfigRequest) Reset 

func (x *DeleteSchemaConfigRequest) Reset()

func (*DeleteSchemaConfigRequest) String 

func (x *DeleteSchemaConfigRequest) String() string

type DeleteSchemaModeRequest 

type DeleteSchemaModeRequest struct {

	// Required. The resource name of subject to delete the mode for. The format
	// is
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/mode/{subject}
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for deleting schema mode.

func (*DeleteSchemaModeRequest) Descriptor deprecated 

func (*DeleteSchemaModeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteSchemaModeRequest.ProtoReflect.Descriptor instead.

func (*DeleteSchemaModeRequest) GetName 

func (x *DeleteSchemaModeRequest) GetName() string

func (*DeleteSchemaModeRequest) ProtoMessage 

func (*DeleteSchemaModeRequest) ProtoMessage()

func (*DeleteSchemaModeRequest) ProtoReflect 

func (x *DeleteSchemaModeRequest) ProtoReflect() protoreflect.Message

func (*DeleteSchemaModeRequest) Reset 

func (x *DeleteSchemaModeRequest) Reset()

func (*DeleteSchemaModeRequest) String 

func (x *DeleteSchemaModeRequest) String() string

type DeleteSchemaRegistryRequest 

type DeleteSchemaRegistryRequest struct {

	// Required. The name of the schema registry instance to delete. Structured
	// like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteSchemaRegistry.

func (*DeleteSchemaRegistryRequest) Descriptor deprecated 

func (*DeleteSchemaRegistryRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteSchemaRegistryRequest.ProtoReflect.Descriptor instead.

func (*DeleteSchemaRegistryRequest) GetName 

func (x *DeleteSchemaRegistryRequest) GetName() string

func (*DeleteSchemaRegistryRequest) ProtoMessage 

func (*DeleteSchemaRegistryRequest) ProtoMessage()

func (*DeleteSchemaRegistryRequest) ProtoReflect 

func (x *DeleteSchemaRegistryRequest) ProtoReflect() protoreflect.Message

func (*DeleteSchemaRegistryRequest) Reset 

func (x *DeleteSchemaRegistryRequest) Reset()

func (*DeleteSchemaRegistryRequest) String 

func (x *DeleteSchemaRegistryRequest) String() string

type DeleteSubjectRequest 

type DeleteSubjectRequest struct {

	// Required. The name of the subject to delete. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. If true, the subject and all associated metadata including the
	// schema ID will be deleted permanently. Otherwise, only the subject is
	// soft-deleted. The default is false. Soft-deleted subjects can still be
	// searched in ListSubjects API call with deleted=true query parameter. A
	// soft-delete of a subject must be performed before a hard-delete.
	Permanent *bool `protobuf:"varint,2,opt,name=permanent,proto3,oneof" json:"permanent,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteSubject.

func (*DeleteSubjectRequest) Descriptor deprecated 

func (*DeleteSubjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteSubjectRequest.ProtoReflect.Descriptor instead.

func (*DeleteSubjectRequest) GetName 

func (x *DeleteSubjectRequest) GetName() string

func (*DeleteSubjectRequest) GetPermanent 

func (x *DeleteSubjectRequest) GetPermanent() bool

func (*DeleteSubjectRequest) ProtoMessage 

func (*DeleteSubjectRequest) ProtoMessage()

func (*DeleteSubjectRequest) ProtoReflect 

func (x *DeleteSubjectRequest) ProtoReflect() protoreflect.Message

func (*DeleteSubjectRequest) Reset 

func (x *DeleteSubjectRequest) Reset()

func (*DeleteSubjectRequest) String 

func (x *DeleteSubjectRequest) String() string

type DeleteVersionRequest 

type DeleteVersionRequest struct {

	// Required. The name of the subject version to delete. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. If true, both the version and the referenced schema ID will be
	// permanently deleted. The default is false. If false, the version will be
	// deleted but the schema ID will be retained. Soft-deleted versions can still
	// be searched in ListVersions API call with deleted=true query parameter. A
	// soft-delete of a version must be performed before a hard-delete.
	Permanent *bool `protobuf:"varint,2,opt,name=permanent,proto3,oneof" json:"permanent,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteVersion.

func (*DeleteVersionRequest) Descriptor deprecated 

func (*DeleteVersionRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteVersionRequest.ProtoReflect.Descriptor instead.

func (*DeleteVersionRequest) GetName 

func (x *DeleteVersionRequest) GetName() string

func (*DeleteVersionRequest) GetPermanent 

func (x *DeleteVersionRequest) GetPermanent() bool

func (*DeleteVersionRequest) ProtoMessage 

func (*DeleteVersionRequest) ProtoMessage()

func (*DeleteVersionRequest) ProtoReflect 

func (x *DeleteVersionRequest) ProtoReflect() protoreflect.Message

func (*DeleteVersionRequest) Reset 

func (x *DeleteVersionRequest) Reset()

func (*DeleteVersionRequest) String 

func (x *DeleteVersionRequest) String() string

type GetContextRequest 

type GetContextRequest struct {

	// Required. The name of the context to return. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for GetContext

func (*GetContextRequest) Descriptor deprecated 

func (*GetContextRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetContextRequest.ProtoReflect.Descriptor instead.

func (*GetContextRequest) GetName 

func (x *GetContextRequest) GetName() string

func (*GetContextRequest) ProtoMessage 

func (*GetContextRequest) ProtoMessage()

func (*GetContextRequest) ProtoReflect 

func (x *GetContextRequest) ProtoReflect() protoreflect.Message

func (*GetContextRequest) Reset 

func (x *GetContextRequest) Reset()

func (*GetContextRequest) String 

func (x *GetContextRequest) String() string

type GetSchemaConfigRequest 

type GetSchemaConfigRequest struct {

	// Required. The resource name to get the config for. It can be either of
	// following:
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config: Get config at global level.
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config/{subject}: Get config for a specific subject.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. If true, the config will fall back to the config at the global
	// level if no subject level config is found.
	DefaultToGlobal *bool `protobuf:"varint,2,opt,name=default_to_global,json=defaultToGlobal,proto3,oneof" json:"default_to_global,omitempty"`
	// contains filtered or unexported fields
}

Request for getting config.

func (*GetSchemaConfigRequest) Descriptor deprecated 

func (*GetSchemaConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSchemaConfigRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaConfigRequest) GetDefaultToGlobal 

func (x *GetSchemaConfigRequest) GetDefaultToGlobal() bool

func (*GetSchemaConfigRequest) GetName 

func (x *GetSchemaConfigRequest) GetName() string

func (*GetSchemaConfigRequest) ProtoMessage 

func (*GetSchemaConfigRequest) ProtoMessage()

func (*GetSchemaConfigRequest) ProtoReflect 

func (x *GetSchemaConfigRequest) ProtoReflect() protoreflect.Message

func (*GetSchemaConfigRequest) Reset 

func (x *GetSchemaConfigRequest) Reset()

func (*GetSchemaConfigRequest) String 

func (x *GetSchemaConfigRequest) String() string

type GetSchemaModeRequest 

type GetSchemaModeRequest struct {

	// Required. The resource name of the mode. The format is
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/mode/{subject}: mode for a schema registry, or
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject}: mode for a specific subject in a specific context
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for getting schema registry or subject mode.

func (*GetSchemaModeRequest) Descriptor deprecated 

func (*GetSchemaModeRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSchemaModeRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaModeRequest) GetName 

func (x *GetSchemaModeRequest) GetName() string

func (*GetSchemaModeRequest) ProtoMessage 

func (*GetSchemaModeRequest) ProtoMessage()

func (*GetSchemaModeRequest) ProtoReflect 

func (x *GetSchemaModeRequest) ProtoReflect() protoreflect.Message

func (*GetSchemaModeRequest) Reset 

func (x *GetSchemaModeRequest) Reset()

func (*GetSchemaModeRequest) String 

func (x *GetSchemaModeRequest) String() string

type GetSchemaRegistryRequest 

type GetSchemaRegistryRequest struct {

	// Required. The name of the schema registry instance to return. Structured
	// like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for GetSchemaRegistry.

func (*GetSchemaRegistryRequest) Descriptor deprecated 

func (*GetSchemaRegistryRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSchemaRegistryRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRegistryRequest) GetName 

func (x *GetSchemaRegistryRequest) GetName() string

func (*GetSchemaRegistryRequest) ProtoMessage 

func (*GetSchemaRegistryRequest) ProtoMessage()

func (*GetSchemaRegistryRequest) ProtoReflect 

func (x *GetSchemaRegistryRequest) ProtoReflect() protoreflect.Message

func (*GetSchemaRegistryRequest) Reset 

func (x *GetSchemaRegistryRequest) Reset()

func (*GetSchemaRegistryRequest) String 

func (x *GetSchemaRegistryRequest) String() string

type GetSchemaRequest 

type GetSchemaRequest struct {

	// Required. The name of the schema to return. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. Used to limit the search for the schema ID to a specific subject,
	// otherwise the schema ID will be searched for in all subjects in the given
	// specified context.
	Subject *string `protobuf:"bytes,2,opt,name=subject,proto3,oneof" json:"subject,omitempty"`
	// contains filtered or unexported fields
}

Request for GetSchema.

func (*GetSchemaRequest) Descriptor deprecated 

func (*GetSchemaRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) GetName 

func (x *GetSchemaRequest) GetName() string

func (*GetSchemaRequest) GetSubject 

func (x *GetSchemaRequest) GetSubject() string

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 GetVersionRequest 

type GetVersionRequest struct {

	// Required. The name of the subject to return versions. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. If true, no matter if the subject/version is soft-deleted or not,
	// it returns the version details. If false, it returns NOT_FOUND error if the
	// subject/version is soft-deleted. The default is false.
	Deleted *bool `protobuf:"varint,2,opt,name=deleted,proto3,oneof" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

Request for GetVersion.

func (*GetVersionRequest) Descriptor deprecated 

func (*GetVersionRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetVersionRequest.ProtoReflect.Descriptor instead.

func (*GetVersionRequest) GetDeleted 

func (x *GetVersionRequest) GetDeleted() bool

func (*GetVersionRequest) GetName 

func (x *GetVersionRequest) GetName() string

func (*GetVersionRequest) ProtoMessage 

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) ProtoReflect 

func (x *GetVersionRequest) ProtoReflect() protoreflect.Message

func (*GetVersionRequest) Reset 

func (x *GetVersionRequest) Reset()

func (*GetVersionRequest) String 

func (x *GetVersionRequest) String() string

type ListContextsRequest 

type ListContextsRequest struct {

	// Required. The parent of the contexts. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

Request for ListContexts.

func (*ListContextsRequest) Descriptor deprecated 

func (*ListContextsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListContextsRequest.ProtoReflect.Descriptor instead.

func (*ListContextsRequest) GetParent 

func (x *ListContextsRequest) GetParent() string

func (*ListContextsRequest) ProtoMessage 

func (*ListContextsRequest) ProtoMessage()

func (*ListContextsRequest) ProtoReflect 

func (x *ListContextsRequest) ProtoReflect() protoreflect.Message

func (*ListContextsRequest) Reset 

func (x *ListContextsRequest) Reset()

func (*ListContextsRequest) String 

func (x *ListContextsRequest) String() string

type ListReferencedSchemasRequest 

type ListReferencedSchemasRequest struct {

	// Required. The version to list referenced by. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

Request for ListReferencedSchemas.

func (*ListReferencedSchemasRequest) Descriptor deprecated 

func (*ListReferencedSchemasRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListReferencedSchemasRequest.ProtoReflect.Descriptor instead.

func (*ListReferencedSchemasRequest) GetParent 

func (x *ListReferencedSchemasRequest) GetParent() string

func (*ListReferencedSchemasRequest) ProtoMessage 

func (*ListReferencedSchemasRequest) ProtoMessage()

func (*ListReferencedSchemasRequest) ProtoReflect 

func (x *ListReferencedSchemasRequest) ProtoReflect() protoreflect.Message

func (*ListReferencedSchemasRequest) Reset 

func (x *ListReferencedSchemasRequest) Reset()

func (*ListReferencedSchemasRequest) String 

func (x *ListReferencedSchemasRequest) String() string

type ListSchemaRegistriesRequest 

type ListSchemaRegistriesRequest struct {

	// Required. The parent whose schema registry instances are to be listed.
	// Structured like: `projects/{project}/locations/{location}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

Request for ListSchemaRegistries.

func (*ListSchemaRegistriesRequest) Descriptor deprecated 

func (*ListSchemaRegistriesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListSchemaRegistriesRequest.ProtoReflect.Descriptor instead.

func (*ListSchemaRegistriesRequest) GetParent 

func (x *ListSchemaRegistriesRequest) GetParent() string

func (*ListSchemaRegistriesRequest) ProtoMessage 

func (*ListSchemaRegistriesRequest) ProtoMessage()

func (*ListSchemaRegistriesRequest) ProtoReflect 

func (x *ListSchemaRegistriesRequest) ProtoReflect() protoreflect.Message

func (*ListSchemaRegistriesRequest) Reset 

func (x *ListSchemaRegistriesRequest) Reset()

func (*ListSchemaRegistriesRequest) String 

func (x *ListSchemaRegistriesRequest) String() string

type ListSchemaRegistriesResponse 

type ListSchemaRegistriesResponse struct {

	// The schema registry instances.
	SchemaRegistries []*SchemaRegistry `protobuf:"bytes,1,rep,name=schema_registries,json=schemaRegistries,proto3" json:"schema_registries,omitempty"`
	// contains filtered or unexported fields
}

Request for ListSchemaRegistries.

func (*ListSchemaRegistriesResponse) Descriptor deprecated 

func (*ListSchemaRegistriesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListSchemaRegistriesResponse.ProtoReflect.Descriptor instead.

func (*ListSchemaRegistriesResponse) GetSchemaRegistries 

func (x *ListSchemaRegistriesResponse) GetSchemaRegistries() []*SchemaRegistry

func (*ListSchemaRegistriesResponse) ProtoMessage 

func (*ListSchemaRegistriesResponse) ProtoMessage()

func (*ListSchemaRegistriesResponse) ProtoReflect 

func (x *ListSchemaRegistriesResponse) ProtoReflect() protoreflect.Message

func (*ListSchemaRegistriesResponse) Reset 

func (x *ListSchemaRegistriesResponse) Reset()

func (*ListSchemaRegistriesResponse) String 

func (x *ListSchemaRegistriesResponse) String() string

type ListSchemaTypesRequest 

type ListSchemaTypesRequest struct {

	// Required. The parent schema registry whose schema types are to be listed.
	// Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

Request for ListSchemaTypes.

func (*ListSchemaTypesRequest) Descriptor deprecated 

func (*ListSchemaTypesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListSchemaTypesRequest.ProtoReflect.Descriptor instead.

func (*ListSchemaTypesRequest) GetParent 

func (x *ListSchemaTypesRequest) GetParent() string

func (*ListSchemaTypesRequest) ProtoMessage 

func (*ListSchemaTypesRequest) ProtoMessage()

func (*ListSchemaTypesRequest) ProtoReflect 

func (x *ListSchemaTypesRequest) ProtoReflect() protoreflect.Message

func (*ListSchemaTypesRequest) Reset 

func (x *ListSchemaTypesRequest) Reset()

func (*ListSchemaTypesRequest) String 

func (x *ListSchemaTypesRequest) String() string

type ListSchemaVersionsRequest 

type ListSchemaVersionsRequest struct {

	// Required. The schema whose schema versions are to be listed. Structured
	// like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/schemas/ids/{schema}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The subject to filter the subjects by.
	Subject *string `protobuf:"bytes,2,opt,name=subject,proto3,oneof" json:"subject,omitempty"`
	// Optional. If true, the response will include soft-deleted versions of the
	// schema, even if the subject is soft-deleted. The default is false.
	Deleted *bool `protobuf:"varint,3,opt,name=deleted,proto3,oneof" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

Request for ListSchemaVersions.

func (*ListSchemaVersionsRequest) Descriptor deprecated 

func (*ListSchemaVersionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListSchemaVersionsRequest.ProtoReflect.Descriptor instead.

func (*ListSchemaVersionsRequest) GetDeleted 

func (x *ListSchemaVersionsRequest) GetDeleted() bool

func (*ListSchemaVersionsRequest) GetParent 

func (x *ListSchemaVersionsRequest) GetParent() string

func (*ListSchemaVersionsRequest) GetSubject 

func (x *ListSchemaVersionsRequest) GetSubject() string

func (*ListSchemaVersionsRequest) ProtoMessage 

func (*ListSchemaVersionsRequest) ProtoMessage()

func (*ListSchemaVersionsRequest) ProtoReflect 

func (x *ListSchemaVersionsRequest) ProtoReflect() protoreflect.Message

func (*ListSchemaVersionsRequest) Reset 

func (x *ListSchemaVersionsRequest) Reset()

func (*ListSchemaVersionsRequest) String 

func (x *ListSchemaVersionsRequest) String() string

type ListSubjectsBySchemaIdRequest 

type ListSubjectsBySchemaIdRequest struct {

	// Required. The schema resource whose associated subjects are to be listed.
	// Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/schemas/ids/{schema}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The subject to filter the subjects by.
	Subject *string `protobuf:"bytes,2,opt,name=subject,proto3,oneof" json:"subject,omitempty"`
	// Optional. If true, the response will include soft-deleted subjects. The
	// default is false.
	Deleted *bool `protobuf:"varint,3,opt,name=deleted,proto3,oneof" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

Request for listing subjects.

func (*ListSubjectsBySchemaIdRequest) Descriptor deprecated 

func (*ListSubjectsBySchemaIdRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListSubjectsBySchemaIdRequest.ProtoReflect.Descriptor instead.

func (*ListSubjectsBySchemaIdRequest) GetDeleted 

func (x *ListSubjectsBySchemaIdRequest) GetDeleted() bool

func (*ListSubjectsBySchemaIdRequest) GetParent 

func (x *ListSubjectsBySchemaIdRequest) GetParent() string

func (*ListSubjectsBySchemaIdRequest) GetSubject 

func (x *ListSubjectsBySchemaIdRequest) GetSubject() string

func (*ListSubjectsBySchemaIdRequest) ProtoMessage 

func (*ListSubjectsBySchemaIdRequest) ProtoMessage()

func (*ListSubjectsBySchemaIdRequest) ProtoReflect 

func (x *ListSubjectsBySchemaIdRequest) ProtoReflect() protoreflect.Message

func (*ListSubjectsBySchemaIdRequest) Reset 

func (x *ListSubjectsBySchemaIdRequest) Reset()

func (*ListSubjectsBySchemaIdRequest) String 

func (x *ListSubjectsBySchemaIdRequest) String() string

type ListSubjectsRequest 

type ListSubjectsRequest struct {

	// Required. The parent schema registry/context whose subjects are to be
	// listed. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The context to filter the subjects by, in the format of
	// `:.{context}:`. If unset, all subjects in the registry are returned. Set to
	// empty string or add as
	// '?subjectPrefix=' at the end of this request to list subjects in the
	// default context.
	SubjectPrefix *string `protobuf:"bytes,2,opt,name=subject_prefix,json=subjectPrefix,proto3,oneof" json:"subject_prefix,omitempty"`
	// Optional. If true, the response will include soft-deleted subjects. The
	// default is false.
	Deleted *bool `protobuf:"varint,3,opt,name=deleted,proto3,oneof" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

Request for listing subjects.

func (*ListSubjectsRequest) Descriptor deprecated 

func (*ListSubjectsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListSubjectsRequest.ProtoReflect.Descriptor instead.

func (*ListSubjectsRequest) GetDeleted 

func (x *ListSubjectsRequest) GetDeleted() bool

func (*ListSubjectsRequest) GetParent 

func (x *ListSubjectsRequest) GetParent() string

func (*ListSubjectsRequest) GetSubjectPrefix 

func (x *ListSubjectsRequest) GetSubjectPrefix() string

func (*ListSubjectsRequest) ProtoMessage 

func (*ListSubjectsRequest) ProtoMessage()

func (*ListSubjectsRequest) ProtoReflect 

func (x *ListSubjectsRequest) ProtoReflect() protoreflect.Message

func (*ListSubjectsRequest) Reset 

func (x *ListSubjectsRequest) Reset()

func (*ListSubjectsRequest) String 

func (x *ListSubjectsRequest) String() string

type ListVersionsRequest 

type ListVersionsRequest struct {

	// Required. The subject whose versions are to be listed. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. If true, the response will include soft-deleted versions of an
	// active or soft-deleted subject. The default is false.
	Deleted *bool `protobuf:"varint,2,opt,name=deleted,proto3,oneof" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

Request for GetVersions.

func (*ListVersionsRequest) Descriptor deprecated 

func (*ListVersionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListVersionsRequest.ProtoReflect.Descriptor instead.

func (*ListVersionsRequest) GetDeleted 

func (x *ListVersionsRequest) GetDeleted() bool

func (*ListVersionsRequest) GetParent 

func (x *ListVersionsRequest) GetParent() string

func (*ListVersionsRequest) ProtoMessage 

func (*ListVersionsRequest) ProtoMessage()

func (*ListVersionsRequest) ProtoReflect 

func (x *ListVersionsRequest) ProtoReflect() protoreflect.Message

func (*ListVersionsRequest) Reset 

func (x *ListVersionsRequest) Reset()

func (*ListVersionsRequest) String 

func (x *ListVersionsRequest) String() string

type LookupVersionRequest 

type LookupVersionRequest struct {

	// Required. The subject to lookup the schema in. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The schema type of the schema.
	SchemaType *Schema_SchemaType `` /* 165-byte string literal not displayed */
	// Required. The schema payload
	Schema string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// Optional. The schema references used by the schema.
	References []*Schema_SchemaReference `protobuf:"bytes,4,rep,name=references,proto3" json:"references,omitempty"`
	// Optional. If true, the schema will be normalized before being looked up.
	// The default is false.
	Normalize *bool `protobuf:"varint,5,opt,name=normalize,proto3,oneof" json:"normalize,omitempty"`
	// Optional. If true, soft-deleted versions will be included in lookup, no
	// matter if the subject is active or soft-deleted. If false, soft-deleted
	// versions will be excluded. The default is false.
	Deleted *bool `protobuf:"varint,6,opt,name=deleted,proto3,oneof" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

Request for LookupVersion.

func (*LookupVersionRequest) Descriptor deprecated 

func (*LookupVersionRequest) Descriptor() ([]byte, []int)

Deprecated: Use LookupVersionRequest.ProtoReflect.Descriptor instead.

func (*LookupVersionRequest) GetDeleted 

func (x *LookupVersionRequest) GetDeleted() bool

func (*LookupVersionRequest) GetNormalize 

func (x *LookupVersionRequest) GetNormalize() bool

func (*LookupVersionRequest) GetParent 

func (x *LookupVersionRequest) GetParent() string

func (*LookupVersionRequest) GetReferences 

func (x *LookupVersionRequest) GetReferences() []*Schema_SchemaReference

func (*LookupVersionRequest) GetSchema 

func (x *LookupVersionRequest) GetSchema() string

func (*LookupVersionRequest) GetSchemaType 

func (x *LookupVersionRequest) GetSchemaType() Schema_SchemaType

func (*LookupVersionRequest) ProtoMessage 

func (*LookupVersionRequest) ProtoMessage()

func (*LookupVersionRequest) ProtoReflect 

func (x *LookupVersionRequest) ProtoReflect() protoreflect.Message

func (*LookupVersionRequest) Reset 

func (x *LookupVersionRequest) Reset()

func (*LookupVersionRequest) String 

func (x *LookupVersionRequest) String() string

type ManagedSchemaRegistryClient 

type ManagedSchemaRegistryClient interface {
	// Get the schema registry instance.
	GetSchemaRegistry(ctx context.Context, in *GetSchemaRegistryRequest, opts ...grpc.CallOption) (*SchemaRegistry, error)
	// List schema registries.
	ListSchemaRegistries(ctx context.Context, in *ListSchemaRegistriesRequest, opts ...grpc.CallOption) (*ListSchemaRegistriesResponse, error)
	// Create a schema registry instance.
	CreateSchemaRegistry(ctx context.Context, in *CreateSchemaRegistryRequest, opts ...grpc.CallOption) (*SchemaRegistry, error)
	// Delete a schema registry instance.
	DeleteSchemaRegistry(ctx context.Context, in *DeleteSchemaRegistryRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Get the context.
	GetContext(ctx context.Context, in *GetContextRequest, opts ...grpc.CallOption) (*Context, error)
	// List contexts for a schema registry.
	ListContexts(ctx context.Context, in *ListContextsRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// Get the schema for the given schema id.
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*Schema, error)
	// Get the schema string for the given schema id.
	// The response will be the schema string.
	GetRawSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// List the schema versions for the given schema id.
	// The response will be an array of subject-version pairs as:
	// [{"subject":"subject1", "version":1}, {"subject":"subject2", "version":2}].
	ListSchemaVersions(ctx context.Context, in *ListSchemaVersionsRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// List the supported schema types.
	// The response will be an array of schema types.
	ListSchemaTypes(ctx context.Context, in *ListSchemaTypesRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// List subjects in the schema registry.
	// The response will be an array of subject names.
	ListSubjects(ctx context.Context, in *ListSubjectsRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// List subjects which reference a particular schema id.
	// The response will be an array of subject names.
	ListSubjectsBySchemaId(ctx context.Context, in *ListSubjectsBySchemaIdRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// Delete a subject.
	// The response will be an array of versions of the deleted subject.
	DeleteSubject(ctx context.Context, in *DeleteSubjectRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// Lookup a schema under the specified subject.
	LookupVersion(ctx context.Context, in *LookupVersionRequest, opts ...grpc.CallOption) (*SchemaVersion, error)
	// Get a versioned schema (schema with subject/version) of a subject.
	GetVersion(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*SchemaVersion, error)
	// Get the schema string only for a version of a subject.
	// The response will be the schema string.
	GetRawSchemaVersion(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// Get all versions of a subject.
	// The response will be an array of versions of the subject.
	ListVersions(ctx context.Context, in *ListVersionsRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// Register a new version under a given subject with the given schema.
	CreateVersion(ctx context.Context, in *CreateVersionRequest, opts ...grpc.CallOption) (*CreateVersionResponse, error)
	// Delete a version of a subject.
	// The response will be the deleted version id.
	DeleteVersion(ctx context.Context, in *DeleteVersionRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// Get a list of IDs of schemas that reference the schema with the given
	// subject and version.
	ListReferencedSchemas(ctx context.Context, in *ListReferencedSchemasRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	// Check compatibility of a schema with all versions or a specific version of
	// a subject.
	CheckCompatibility(ctx context.Context, in *CheckCompatibilityRequest, opts ...grpc.CallOption) (*CheckCompatibilityResponse, error)
	// Get schema config at global level or for a subject.
	GetSchemaConfig(ctx context.Context, in *GetSchemaConfigRequest, opts ...grpc.CallOption) (*SchemaConfig, error)
	// Update config at global level or for a subject.
	// Creates a SchemaSubject-level SchemaConfig if it does not exist.
	UpdateSchemaConfig(ctx context.Context, in *UpdateSchemaConfigRequest, opts ...grpc.CallOption) (*SchemaConfig, error)
	// Delete schema config for a subject.
	DeleteSchemaConfig(ctx context.Context, in *DeleteSchemaConfigRequest, opts ...grpc.CallOption) (*SchemaConfig, error)
	// Get mode at global level or for a subject.
	GetSchemaMode(ctx context.Context, in *GetSchemaModeRequest, opts ...grpc.CallOption) (*SchemaMode, error)
	// Update mode at global level or for a subject.
	UpdateSchemaMode(ctx context.Context, in *UpdateSchemaModeRequest, opts ...grpc.CallOption) (*SchemaMode, error)
	// Delete schema mode for a subject.
	DeleteSchemaMode(ctx context.Context, in *DeleteSchemaModeRequest, opts ...grpc.CallOption) (*SchemaMode, error)
}

ManagedSchemaRegistryClient is the client API for ManagedSchemaRegistry 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 NewManagedSchemaRegistryClient 

func NewManagedSchemaRegistryClient(cc grpc.ClientConnInterface) ManagedSchemaRegistryClient

type ManagedSchemaRegistryServer 

type ManagedSchemaRegistryServer interface {
	// Get the schema registry instance.
	GetSchemaRegistry(context.Context, *GetSchemaRegistryRequest) (*SchemaRegistry, error)
	// List schema registries.
	ListSchemaRegistries(context.Context, *ListSchemaRegistriesRequest) (*ListSchemaRegistriesResponse, error)
	// Create a schema registry instance.
	CreateSchemaRegistry(context.Context, *CreateSchemaRegistryRequest) (*SchemaRegistry, error)
	// Delete a schema registry instance.
	DeleteSchemaRegistry(context.Context, *DeleteSchemaRegistryRequest) (*emptypb.Empty, error)
	// Get the context.
	GetContext(context.Context, *GetContextRequest) (*Context, error)
	// List contexts for a schema registry.
	ListContexts(context.Context, *ListContextsRequest) (*httpbody.HttpBody, error)
	// Get the schema for the given schema id.
	GetSchema(context.Context, *GetSchemaRequest) (*Schema, error)
	// Get the schema string for the given schema id.
	// The response will be the schema string.
	GetRawSchema(context.Context, *GetSchemaRequest) (*httpbody.HttpBody, error)
	// List the schema versions for the given schema id.
	// The response will be an array of subject-version pairs as:
	// [{"subject":"subject1", "version":1}, {"subject":"subject2", "version":2}].
	ListSchemaVersions(context.Context, *ListSchemaVersionsRequest) (*httpbody.HttpBody, error)
	// List the supported schema types.
	// The response will be an array of schema types.
	ListSchemaTypes(context.Context, *ListSchemaTypesRequest) (*httpbody.HttpBody, error)
	// List subjects in the schema registry.
	// The response will be an array of subject names.
	ListSubjects(context.Context, *ListSubjectsRequest) (*httpbody.HttpBody, error)
	// List subjects which reference a particular schema id.
	// The response will be an array of subject names.
	ListSubjectsBySchemaId(context.Context, *ListSubjectsBySchemaIdRequest) (*httpbody.HttpBody, error)
	// Delete a subject.
	// The response will be an array of versions of the deleted subject.
	DeleteSubject(context.Context, *DeleteSubjectRequest) (*httpbody.HttpBody, error)
	// Lookup a schema under the specified subject.
	LookupVersion(context.Context, *LookupVersionRequest) (*SchemaVersion, error)
	// Get a versioned schema (schema with subject/version) of a subject.
	GetVersion(context.Context, *GetVersionRequest) (*SchemaVersion, error)
	// Get the schema string only for a version of a subject.
	// The response will be the schema string.
	GetRawSchemaVersion(context.Context, *GetVersionRequest) (*httpbody.HttpBody, error)
	// Get all versions of a subject.
	// The response will be an array of versions of the subject.
	ListVersions(context.Context, *ListVersionsRequest) (*httpbody.HttpBody, error)
	// Register a new version under a given subject with the given schema.
	CreateVersion(context.Context, *CreateVersionRequest) (*CreateVersionResponse, error)
	// Delete a version of a subject.
	// The response will be the deleted version id.
	DeleteVersion(context.Context, *DeleteVersionRequest) (*httpbody.HttpBody, error)
	// Get a list of IDs of schemas that reference the schema with the given
	// subject and version.
	ListReferencedSchemas(context.Context, *ListReferencedSchemasRequest) (*httpbody.HttpBody, error)
	// Check compatibility of a schema with all versions or a specific version of
	// a subject.
	CheckCompatibility(context.Context, *CheckCompatibilityRequest) (*CheckCompatibilityResponse, error)
	// Get schema config at global level or for a subject.
	GetSchemaConfig(context.Context, *GetSchemaConfigRequest) (*SchemaConfig, error)
	// Update config at global level or for a subject.
	// Creates a SchemaSubject-level SchemaConfig if it does not exist.
	UpdateSchemaConfig(context.Context, *UpdateSchemaConfigRequest) (*SchemaConfig, error)
	// Delete schema config for a subject.
	DeleteSchemaConfig(context.Context, *DeleteSchemaConfigRequest) (*SchemaConfig, error)
	// Get mode at global level or for a subject.
	GetSchemaMode(context.Context, *GetSchemaModeRequest) (*SchemaMode, error)
	// Update mode at global level or for a subject.
	UpdateSchemaMode(context.Context, *UpdateSchemaModeRequest) (*SchemaMode, error)
	// Delete schema mode for a subject.
	DeleteSchemaMode(context.Context, *DeleteSchemaModeRequest) (*SchemaMode, error)
}

ManagedSchemaRegistryServer is the server API for ManagedSchemaRegistry service. All implementations should embed UnimplementedManagedSchemaRegistryServer for forward compatibility

type Schema 

type Schema struct {

	// Optional. The schema type of the schema.
	SchemaType Schema_SchemaType `` /* 159-byte string literal not displayed */
	// The schema payload.
	SchemaPayload string `protobuf:"bytes,2,opt,name=schema_payload,json=schema,proto3" json:"schema_payload,omitempty"`
	// Optional. The schema references used by the schema.
	References []*Schema_SchemaReference `protobuf:"bytes,3,rep,name=references,proto3" json:"references,omitempty"`
	// contains filtered or unexported fields
}

Schema for a Kafka message.

func (*Schema) Descriptor deprecated 

func (*Schema) Descriptor() ([]byte, []int)

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetReferences 

func (x *Schema) GetReferences() []*Schema_SchemaReference

func (*Schema) GetSchemaPayload 

func (x *Schema) GetSchemaPayload() string

func (*Schema) GetSchemaType 

func (x *Schema) GetSchemaType() Schema_SchemaType

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

func (x *Schema) ProtoReflect() protoreflect.Message

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

type SchemaConfig 

type SchemaConfig struct {

	// Required. The compatibility type of the schema.
	// The default value is BACKWARD.
	// If unset in a SchemaSubject-level SchemaConfig, defaults to the global
	// value. If unset in a SchemaRegistry-level SchemaConfig, reverts to the
	// default value.
	Compatibility *SchemaConfig_CompatibilityType `` /* 166-byte string literal not displayed */
	// Optional. If true, the schema will be normalized before being stored or
	// looked up. The default is false. If unset in a SchemaSubject-level
	// SchemaConfig, the global value will be used. If unset in a
	// SchemaRegistry-level SchemaConfig, reverts to the default value.
	Normalize *bool `protobuf:"varint,2,opt,name=normalize,proto3,oneof" json:"normalize,omitempty"`
	// Optional. The subject to which this subject is an alias of. Only applicable
	// for subject config.
	Alias string `protobuf:"bytes,3,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

SchemaConfig represents configuration for a schema registry or a specific subject.

func (*SchemaConfig) Descriptor deprecated 

func (*SchemaConfig) Descriptor() ([]byte, []int)

Deprecated: Use SchemaConfig.ProtoReflect.Descriptor instead.

func (*SchemaConfig) GetAlias 

func (x *SchemaConfig) GetAlias() string

func (*SchemaConfig) GetCompatibility 

func (x *SchemaConfig) GetCompatibility() SchemaConfig_CompatibilityType

func (*SchemaConfig) GetNormalize 

func (x *SchemaConfig) GetNormalize() bool

func (*SchemaConfig) ProtoMessage 

func (*SchemaConfig) ProtoMessage()

func (*SchemaConfig) ProtoReflect 

func (x *SchemaConfig) ProtoReflect() protoreflect.Message

func (*SchemaConfig) Reset 

func (x *SchemaConfig) Reset()

func (*SchemaConfig) String 

func (x *SchemaConfig) String() string

type SchemaConfig_CompatibilityType 

type SchemaConfig_CompatibilityType int32

Compatibility type of the schemas. 

const (
	// No compatibility check.
	SchemaConfig_NONE SchemaConfig_CompatibilityType = 0
	// Backwards compatible with the most recent version.
	SchemaConfig_BACKWARD SchemaConfig_CompatibilityType = 1
	// Backwards compatible with all previous versions.
	SchemaConfig_BACKWARD_TRANSITIVE SchemaConfig_CompatibilityType = 2
	// Forwards compatible with the most recent version.
	SchemaConfig_FORWARD SchemaConfig_CompatibilityType = 3
	// Forwards compatible with all previous versions.
	SchemaConfig_FORWARD_TRANSITIVE SchemaConfig_CompatibilityType = 4
	// Backwards and forwards compatible with the most recent version.
	SchemaConfig_FULL SchemaConfig_CompatibilityType = 5
	// Backwards and forwards compatible with all previous versions.
	SchemaConfig_FULL_TRANSITIVE SchemaConfig_CompatibilityType = 6
)

func (SchemaConfig_CompatibilityType) Descriptor 

func (SchemaConfig_CompatibilityType) Descriptor() protoreflect.EnumDescriptor

func (SchemaConfig_CompatibilityType) Enum 

func (x SchemaConfig_CompatibilityType) Enum() *SchemaConfig_CompatibilityType

func (SchemaConfig_CompatibilityType) EnumDescriptor deprecated 

func (SchemaConfig_CompatibilityType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SchemaConfig_CompatibilityType.Descriptor instead.

func (SchemaConfig_CompatibilityType) Number 

func (x SchemaConfig_CompatibilityType) Number() protoreflect.EnumNumber

func (SchemaConfig_CompatibilityType) String 

func (x SchemaConfig_CompatibilityType) String() string

func (SchemaConfig_CompatibilityType) Type 

func (SchemaConfig_CompatibilityType) Type() protoreflect.EnumType

type SchemaMode 

type SchemaMode struct {

	// Required. The mode type of a schema registry (READWRITE by default) or of a
	// subject (unset by default, which means use the global schema registry
	// setting).
	Mode SchemaMode_ModeType `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

SchemaMode represents the mode of a schema registry or a specific subject. Four modes are supported: * NONE: deprecated. This was the default mode for a subject, but now the default is unset (which means use the global schema registry setting) * READONLY: The schema registry is in read-only mode. * READWRITE: The schema registry is in read-write mode, which allows limited write operations on the schema. * IMPORT: The schema registry is in import mode, which allows more editing operations on the schema for data importing purposes.

func (*SchemaMode) Descriptor deprecated 

func (*SchemaMode) Descriptor() ([]byte, []int)

Deprecated: Use SchemaMode.ProtoReflect.Descriptor instead.

func (*SchemaMode) GetMode 

func (x *SchemaMode) GetMode() SchemaMode_ModeType

func (*SchemaMode) ProtoMessage 

func (*SchemaMode) ProtoMessage()

func (*SchemaMode) ProtoReflect 

func (x *SchemaMode) ProtoReflect() protoreflect.Message

func (*SchemaMode) Reset 

func (x *SchemaMode) Reset()

func (*SchemaMode) String 

func (x *SchemaMode) String() string

type SchemaMode_ModeType 

type SchemaMode_ModeType int32

Mode type of the schemas or subjects. 

const (
	// The default / unset value.
	// The subject mode is NONE/unset by default, which means use the global
	// schema registry mode. This should not be used for setting the mode.
	SchemaMode_NONE SchemaMode_ModeType = 0
	// READONLY mode.
	SchemaMode_READONLY SchemaMode_ModeType = 1
	// READWRITE mode.
	SchemaMode_READWRITE SchemaMode_ModeType = 2
	// IMPORT mode.
	SchemaMode_IMPORT SchemaMode_ModeType = 3
)

func (SchemaMode_ModeType) Descriptor 

func (SchemaMode_ModeType) Descriptor() protoreflect.EnumDescriptor

func (SchemaMode_ModeType) Enum 

func (x SchemaMode_ModeType) Enum() *SchemaMode_ModeType

func (SchemaMode_ModeType) EnumDescriptor deprecated 

func (SchemaMode_ModeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SchemaMode_ModeType.Descriptor instead.

func (SchemaMode_ModeType) Number 

func (x SchemaMode_ModeType) Number() protoreflect.EnumNumber

func (SchemaMode_ModeType) String 

func (x SchemaMode_ModeType) String() string

func (SchemaMode_ModeType) Type 

func (SchemaMode_ModeType) Type() protoreflect.EnumType

type SchemaRegistry 

type SchemaRegistry struct {

	// Identifier. The name of the schema registry instance. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}`
	// The instance name {schema_registry} can contain the following:
	// * Up to 255 characters.
	// * Letters (uppercase or lowercase), numbers, and underscores.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The contexts of the schema registry instance.
	Contexts []string `protobuf:"bytes,2,rep,name=contexts,proto3" json:"contexts,omitempty"`
	// contains filtered or unexported fields
}

SchemaRegistry is a schema registry instance.

func (*SchemaRegistry) Descriptor deprecated 

func (*SchemaRegistry) Descriptor() ([]byte, []int)

Deprecated: Use SchemaRegistry.ProtoReflect.Descriptor instead.

func (*SchemaRegistry) GetContexts 

func (x *SchemaRegistry) GetContexts() []string

func (*SchemaRegistry) GetName 

func (x *SchemaRegistry) GetName() string

func (*SchemaRegistry) ProtoMessage 

func (*SchemaRegistry) ProtoMessage()

func (*SchemaRegistry) ProtoReflect 

func (x *SchemaRegistry) ProtoReflect() protoreflect.Message

func (*SchemaRegistry) Reset 

func (x *SchemaRegistry) Reset()

func (*SchemaRegistry) String 

func (x *SchemaRegistry) String() string

type SchemaSubject 

type SchemaSubject struct {

	// The name of the subject. Structured like:
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}`
	// or
	// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}`
	//
	// Subject name {subject} can contain the following:
	// * Up to 255 UTF-8 bytes.
	// * Allowed characters: letters (uppercase or lowercase), numbers, and the
	// following special characters: `.`, `-`, `_`, `+`, `%`, and `~`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The versions of the subject.
	Versions []string `protobuf:"bytes,3,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

Subject defines the evolution scope of schemas as a holder of schema versions.

func (*SchemaSubject) Descriptor deprecated 

func (*SchemaSubject) Descriptor() ([]byte, []int)

Deprecated: Use SchemaSubject.ProtoReflect.Descriptor instead.

func (*SchemaSubject) GetName 

func (x *SchemaSubject) GetName() string

func (*SchemaSubject) GetVersions 

func (x *SchemaSubject) GetVersions() []string

func (*SchemaSubject) ProtoMessage 

func (*SchemaSubject) ProtoMessage()

func (*SchemaSubject) ProtoReflect 

func (x *SchemaSubject) ProtoReflect() protoreflect.Message

func (*SchemaSubject) Reset 

func (x *SchemaSubject) Reset()

func (*SchemaSubject) String 

func (x *SchemaSubject) String() string

type SchemaVersion 

type SchemaVersion struct {

	// Required. The subject of the version.
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	// Required. The version ID
	VersionId int32 `protobuf:"varint,2,opt,name=version_id,json=version,proto3" json:"version_id,omitempty"`
	// Required. The schema ID.
	SchemaId int32 `protobuf:"varint,3,opt,name=schema_id,json=id,proto3" json:"schema_id,omitempty"`
	// Optional. The schema type of the schema.
	SchemaType Schema_SchemaType `` /* 159-byte string literal not displayed */
	// Required. The schema payload.
	SchemaPayload string `protobuf:"bytes,5,opt,name=schema_payload,json=schema,proto3" json:"schema_payload,omitempty"`
	// Optional. The schema references used by the schema.
	References []*Schema_SchemaReference `protobuf:"bytes,6,rep,name=references,proto3" json:"references,omitempty"`
	// contains filtered or unexported fields
}

Version of a schema.

func (*SchemaVersion) Descriptor deprecated 

func (*SchemaVersion) Descriptor() ([]byte, []int)

Deprecated: Use SchemaVersion.ProtoReflect.Descriptor instead.

func (*SchemaVersion) GetReferences 

func (x *SchemaVersion) GetReferences() []*Schema_SchemaReference

func (*SchemaVersion) GetSchemaId 

func (x *SchemaVersion) GetSchemaId() int32

func (*SchemaVersion) GetSchemaPayload 

func (x *SchemaVersion) GetSchemaPayload() string

func (*SchemaVersion) GetSchemaType 

func (x *SchemaVersion) GetSchemaType() Schema_SchemaType

func (*SchemaVersion) GetSubject 

func (x *SchemaVersion) GetSubject() string

func (*SchemaVersion) GetVersionId 

func (x *SchemaVersion) GetVersionId() int32

func (*SchemaVersion) ProtoMessage 

func (*SchemaVersion) ProtoMessage()

func (*SchemaVersion) ProtoReflect 

func (x *SchemaVersion) ProtoReflect() protoreflect.Message

func (*SchemaVersion) Reset 

func (x *SchemaVersion) Reset()

func (*SchemaVersion) String 

func (x *SchemaVersion) String() string

type Schema_SchemaReference 

type Schema_SchemaReference struct {

	// Required. The name of the reference.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The subject of the reference.
	Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	// Required. The version of the reference.
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

SchemaReference is a reference to a schema.

func (*Schema_SchemaReference) Descriptor deprecated 

func (*Schema_SchemaReference) Descriptor() ([]byte, []int)

Deprecated: Use Schema_SchemaReference.ProtoReflect.Descriptor instead.

func (*Schema_SchemaReference) GetName 

func (x *Schema_SchemaReference) GetName() string

func (*Schema_SchemaReference) GetSubject 

func (x *Schema_SchemaReference) GetSubject() string

func (*Schema_SchemaReference) GetVersion 

func (x *Schema_SchemaReference) GetVersion() int32

func (*Schema_SchemaReference) ProtoMessage 

func (*Schema_SchemaReference) ProtoMessage()

func (*Schema_SchemaReference) ProtoReflect 

func (x *Schema_SchemaReference) ProtoReflect() protoreflect.Message

func (*Schema_SchemaReference) Reset 

func (x *Schema_SchemaReference) Reset()

func (*Schema_SchemaReference) String 

func (x *Schema_SchemaReference) String() string

type Schema_SchemaType 

type Schema_SchemaType int32

Schema types. 

const (
	// No schema type. The default will be AVRO.
	Schema_SCHEMA_TYPE_UNSPECIFIED Schema_SchemaType = 0
	// Avro schema type.
	Schema_AVRO Schema_SchemaType = 1
	// JSON schema type.
	Schema_JSON Schema_SchemaType = 2
	// Protobuf schema type.
	Schema_PROTOBUF Schema_SchemaType = 3
)

func (Schema_SchemaType) Descriptor 

func (Schema_SchemaType) Descriptor() protoreflect.EnumDescriptor

func (Schema_SchemaType) Enum 

func (x Schema_SchemaType) Enum() *Schema_SchemaType

func (Schema_SchemaType) EnumDescriptor deprecated 

func (Schema_SchemaType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Schema_SchemaType.Descriptor instead.

func (Schema_SchemaType) Number 

func (x Schema_SchemaType) Number() protoreflect.EnumNumber

func (Schema_SchemaType) String 

func (x Schema_SchemaType) String() string

func (Schema_SchemaType) Type 

func (Schema_SchemaType) Type() protoreflect.EnumType

type UnimplementedManagedSchemaRegistryServer 

type UnimplementedManagedSchemaRegistryServer struct {
}

UnimplementedManagedSchemaRegistryServer should be embedded to have forward compatible implementations.

func (UnimplementedManagedSchemaRegistryServer) CheckCompatibility 

func (UnimplementedManagedSchemaRegistryServer) CheckCompatibility(context.Context, *CheckCompatibilityRequest) (*CheckCompatibilityResponse, error)

func (UnimplementedManagedSchemaRegistryServer) CreateSchemaRegistry 

func (UnimplementedManagedSchemaRegistryServer) CreateSchemaRegistry(context.Context, *CreateSchemaRegistryRequest) (*SchemaRegistry, error)

func (UnimplementedManagedSchemaRegistryServer) CreateVersion 

func (UnimplementedManagedSchemaRegistryServer) CreateVersion(context.Context, *CreateVersionRequest) (*CreateVersionResponse, error)

func (UnimplementedManagedSchemaRegistryServer) DeleteSchemaConfig 

func (UnimplementedManagedSchemaRegistryServer) DeleteSchemaConfig(context.Context, *DeleteSchemaConfigRequest) (*SchemaConfig, error)

func (UnimplementedManagedSchemaRegistryServer) DeleteSchemaMode 

func (UnimplementedManagedSchemaRegistryServer) DeleteSchemaMode(context.Context, *DeleteSchemaModeRequest) (*SchemaMode, error)

func (UnimplementedManagedSchemaRegistryServer) DeleteSchemaRegistry 

func (UnimplementedManagedSchemaRegistryServer) DeleteSchemaRegistry(context.Context, *DeleteSchemaRegistryRequest) (*emptypb.Empty, error)

func (UnimplementedManagedSchemaRegistryServer) DeleteSubject 

func (UnimplementedManagedSchemaRegistryServer) DeleteSubject(context.Context, *DeleteSubjectRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) DeleteVersion 

func (UnimplementedManagedSchemaRegistryServer) DeleteVersion(context.Context, *DeleteVersionRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) GetContext 

func (UnimplementedManagedSchemaRegistryServer) GetContext(context.Context, *GetContextRequest) (*Context, error)

func (UnimplementedManagedSchemaRegistryServer) GetRawSchema 

func (UnimplementedManagedSchemaRegistryServer) GetRawSchema(context.Context, *GetSchemaRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) GetRawSchemaVersion 

func (UnimplementedManagedSchemaRegistryServer) GetRawSchemaVersion(context.Context, *GetVersionRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) GetSchema 

func (UnimplementedManagedSchemaRegistryServer) GetSchema(context.Context, *GetSchemaRequest) (*Schema, error)

func (UnimplementedManagedSchemaRegistryServer) GetSchemaConfig 

func (UnimplementedManagedSchemaRegistryServer) GetSchemaConfig(context.Context, *GetSchemaConfigRequest) (*SchemaConfig, error)

func (UnimplementedManagedSchemaRegistryServer) GetSchemaMode 

func (UnimplementedManagedSchemaRegistryServer) GetSchemaMode(context.Context, *GetSchemaModeRequest) (*SchemaMode, error)

func (UnimplementedManagedSchemaRegistryServer) GetSchemaRegistry 

func (UnimplementedManagedSchemaRegistryServer) GetSchemaRegistry(context.Context, *GetSchemaRegistryRequest) (*SchemaRegistry, error)

func (UnimplementedManagedSchemaRegistryServer) GetVersion 

func (UnimplementedManagedSchemaRegistryServer) GetVersion(context.Context, *GetVersionRequest) (*SchemaVersion, error)

func (UnimplementedManagedSchemaRegistryServer) ListContexts 

func (UnimplementedManagedSchemaRegistryServer) ListContexts(context.Context, *ListContextsRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) ListReferencedSchemas 

func (UnimplementedManagedSchemaRegistryServer) ListReferencedSchemas(context.Context, *ListReferencedSchemasRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) ListSchemaRegistries 

func (UnimplementedManagedSchemaRegistryServer) ListSchemaRegistries(context.Context, *ListSchemaRegistriesRequest) (*ListSchemaRegistriesResponse, error)

func (UnimplementedManagedSchemaRegistryServer) ListSchemaTypes 

func (UnimplementedManagedSchemaRegistryServer) ListSchemaTypes(context.Context, *ListSchemaTypesRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) ListSchemaVersions 

func (UnimplementedManagedSchemaRegistryServer) ListSchemaVersions(context.Context, *ListSchemaVersionsRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) ListSubjects 

func (UnimplementedManagedSchemaRegistryServer) ListSubjects(context.Context, *ListSubjectsRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) ListSubjectsBySchemaId 

func (UnimplementedManagedSchemaRegistryServer) ListSubjectsBySchemaId(context.Context, *ListSubjectsBySchemaIdRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) ListVersions 

func (UnimplementedManagedSchemaRegistryServer) ListVersions(context.Context, *ListVersionsRequest) (*httpbody.HttpBody, error)

func (UnimplementedManagedSchemaRegistryServer) LookupVersion 

func (UnimplementedManagedSchemaRegistryServer) LookupVersion(context.Context, *LookupVersionRequest) (*SchemaVersion, error)

func (UnimplementedManagedSchemaRegistryServer) UpdateSchemaConfig 

func (UnimplementedManagedSchemaRegistryServer) UpdateSchemaConfig(context.Context, *UpdateSchemaConfigRequest) (*SchemaConfig, error)

func (UnimplementedManagedSchemaRegistryServer) UpdateSchemaMode 

func (UnimplementedManagedSchemaRegistryServer) UpdateSchemaMode(context.Context, *UpdateSchemaModeRequest) (*SchemaMode, error)

type UnsafeManagedSchemaRegistryServer added in v0.8.1 

type UnsafeManagedSchemaRegistryServer interface {
	// contains filtered or unexported methods
}

UnsafeManagedSchemaRegistryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManagedSchemaRegistryServer will result in compilation errors.

type UpdateSchemaConfigRequest 

type UpdateSchemaConfigRequest struct {

	// Required. The resource name to update the config for. It can be either of
	// following:
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config: Update config at global level.
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config/{subject}: Update config for a specific subject.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The compatibility type of the schemas.
	// Cannot be unset for a SchemaRegistry-level SchemaConfig.
	// If unset on a SchemaSubject-level SchemaConfig, removes the compatibility
	// field for the SchemaConfig.
	Compatibility *SchemaConfig_CompatibilityType `` /* 166-byte string literal not displayed */
	// Optional. If true, the schema will be normalized before being stored or
	// looked up. The default is false. Cannot be unset for a SchemaRegistry-level
	// SchemaConfig. If unset on a SchemaSubject-level SchemaConfig, removes the
	// normalize field for the SchemaConfig.
	Normalize *bool `protobuf:"varint,3,opt,name=normalize,proto3,oneof" json:"normalize,omitempty"`
	// contains filtered or unexported fields
}

Request for updating schema config. On a SchemaSubject-level SchemaConfig, an unset field will be removed from the SchemaConfig.

func (*UpdateSchemaConfigRequest) Descriptor deprecated 

func (*UpdateSchemaConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSchemaConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateSchemaConfigRequest) GetCompatibility 

func (x *UpdateSchemaConfigRequest) GetCompatibility() SchemaConfig_CompatibilityType

func (*UpdateSchemaConfigRequest) GetName 

func (x *UpdateSchemaConfigRequest) GetName() string

func (*UpdateSchemaConfigRequest) GetNormalize 

func (x *UpdateSchemaConfigRequest) GetNormalize() bool

func (*UpdateSchemaConfigRequest) ProtoMessage 

func (*UpdateSchemaConfigRequest) ProtoMessage()

func (*UpdateSchemaConfigRequest) ProtoReflect 

func (x *UpdateSchemaConfigRequest) ProtoReflect() protoreflect.Message

func (*UpdateSchemaConfigRequest) Reset 

func (x *UpdateSchemaConfigRequest) Reset()

func (*UpdateSchemaConfigRequest) String 

func (x *UpdateSchemaConfigRequest) String() string

type UpdateSchemaModeRequest 

type UpdateSchemaModeRequest struct {

	// Required. The resource name of the mode. The format is
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/mode/{subject}: mode for a schema registry, or
	//   - projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject}: mode for a specific subject in a specific context
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The mode type.
	Mode SchemaMode_ModeType `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request for updating schema registry or subject mode.

func (*UpdateSchemaModeRequest) Descriptor deprecated 

func (*UpdateSchemaModeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSchemaModeRequest.ProtoReflect.Descriptor instead.

func (*UpdateSchemaModeRequest) GetMode 

func (x *UpdateSchemaModeRequest) GetMode() SchemaMode_ModeType

func (*UpdateSchemaModeRequest) GetName 

func (x *UpdateSchemaModeRequest) GetName() string

func (*UpdateSchemaModeRequest) ProtoMessage 

func (*UpdateSchemaModeRequest) ProtoMessage()

func (*UpdateSchemaModeRequest) ProtoReflect 

func (x *UpdateSchemaModeRequest) ProtoReflect() protoreflect.Message

func (*UpdateSchemaModeRequest) Reset 

func (x *UpdateSchemaModeRequest) Reset()

func (*UpdateSchemaModeRequest) String 

func (x *UpdateSchemaModeRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.