schemas

package
v2.11.0 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_strmprivacy_api_schemas_v1_schemas_v1_proto protoreflect.FileDescriptor
View Source 
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,
		},
	},
	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 CreateSchemaRequest 

type CreateSchemaRequest struct {
	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"`
	// contains filtered or unexported fields
}

func (*CreateSchemaRequest) Descriptor deprecated 

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

Deprecated: Use CreateSchemaRequest.ProtoReflect.Descriptor instead.

func (*CreateSchemaRequest) GetBillingId 

func (x *CreateSchemaRequest) GetBillingId() 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 GetSchemaCodeRequest 

type GetSchemaCodeRequest struct {
	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 

func (x *GetSchemaCodeRequest) GetBillingId() string

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 GetSchemaRequest 

type GetSchemaRequest struct {
	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 

func (x *GetSchemaRequest) GetBillingId() string

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)
}

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)
	// contains filtered or unexported methods
}

SchemasServiceServer is the server API for SchemasService service. All implementations must embed UnimplementedSchemasServiceServer for forward compatibility

type UnimplementedSchemasServiceServer 

type UnimplementedSchemasServiceServer struct {
}

UnimplementedSchemasServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSchemasServiceServer) CreateSchema 

func (UnimplementedSchemasServiceServer) CreateSchema(context.Context, *CreateSchemaRequest) (*CreateSchemaResponse, 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) 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 {
	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"`
	// contains filtered or unexported fields
}

func (*UpdateSchemaRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSchemaRequest.ProtoReflect.Descriptor instead.

func (*UpdateSchemaRequest) GetBillingId 

func (x *UpdateSchemaRequest) GetBillingId() string

func (*UpdateSchemaRequest) GetChecksum 

func (x *UpdateSchemaRequest) GetChecksum() 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

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.