definition

package
v0.0.0-...-f6e20dd Latest Latest
Warning

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

Go to latest
Published: Oct 17, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Name = "meta.v1"
)

Variables

View Source
var File_integrations_meta_v1_definition_definition_proto protoreflect.FileDescriptor
View Source
var MetaV1_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "meta.MetaV1",
	HandlerType: (*MetaV1Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _MetaV1_Get_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _MetaV1_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _MetaV1_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "List",
			Handler:       _MetaV1_List_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "integrations/meta/v1/definition/definition.proto",
}

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

Functions

func RegisterMetaV1Server

func RegisterMetaV1Server(s grpc.ServiceRegistrar, srv MetaV1Server)

Types

type ListRequest

type ListRequest struct {

	// Refines the batch size
	Batch *int32 `protobuf:"varint,1,opt,name=batch,proto3,oneof" json:"batch,omitempty"`
	// Defines the object prefix
	Prefix *string `protobuf:"bytes,2,opt,name=prefix,proto3,oneof" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

ListRequest defines request for MetaV1 Object List Request

func (*ListRequest) Descriptor deprecated

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetBatch

func (x *ListRequest) GetBatch() int32

func (*ListRequest) GetPrefix

func (x *ListRequest) GetPrefix() string

func (*ListRequest) ProtoMessage

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect

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

func (*ListRequest) Reset

func (x *ListRequest) Reset()

func (*ListRequest) String

func (x *ListRequest) String() string

type ListResponseChunk

type ListResponseChunk struct {

	// Returns list of keys
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

ListResponseChunk defines chunk response for MetaV1 Object List Request

func (*ListResponseChunk) Descriptor deprecated

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

Deprecated: Use ListResponseChunk.ProtoReflect.Descriptor instead.

func (*ListResponseChunk) GetKeys

func (x *ListResponseChunk) GetKeys() []string

func (*ListResponseChunk) ProtoMessage

func (*ListResponseChunk) ProtoMessage()

func (*ListResponseChunk) ProtoReflect

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

func (*ListResponseChunk) Reset

func (x *ListResponseChunk) Reset()

func (*ListResponseChunk) String

func (x *ListResponseChunk) String() string

type MetaV1Client

type MetaV1Client interface {
	// Get returns the Object from the Meta Store. If TTL is set to 0, result is not cached
	Get(ctx context.Context, in *ObjectRequest, opts ...grpc.CallOption) (*ObjectResponse, error)
	// Set saves the object in the Meta Store
	// Optionally, will check Revision for the conflict management
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*ObjectResponse, error)
	// Delete deletes the object from the Meta Store
	Delete(ctx context.Context, in *ObjectRequest, opts ...grpc.CallOption) (*definition.Empty, error)
	// List lists the object from the Meta Store
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (MetaV1_ListClient, error)
}

MetaV1Client is the client API for MetaV1 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 NewMetaV1Client

func NewMetaV1Client(cc grpc.ClientConnInterface) MetaV1Client

type MetaV1Server

type MetaV1Server interface {
	// Get returns the Object from the Meta Store. If TTL is set to 0, result is not cached
	Get(context.Context, *ObjectRequest) (*ObjectResponse, error)
	// Set saves the object in the Meta Store
	// Optionally, will check Revision for the conflict management
	Set(context.Context, *SetRequest) (*ObjectResponse, error)
	// Delete deletes the object from the Meta Store
	Delete(context.Context, *ObjectRequest) (*definition.Empty, error)
	// List lists the object from the Meta Store
	List(*ListRequest, MetaV1_ListServer) error
	// contains filtered or unexported methods
}

MetaV1Server is the server API for MetaV1 service. All implementations must embed UnimplementedMetaV1Server for forward compatibility

type MetaV1_ListClient

type MetaV1_ListClient interface {
	Recv() (*ListResponseChunk, error)
	grpc.ClientStream
}

type MetaV1_ListServer

type MetaV1_ListServer interface {
	Send(*ListResponseChunk) error
	grpc.ServerStream
}

type ObjectRequest

type ObjectRequest struct {

	// Key defines the Object Key (optionally, prefixed with global prefix)
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

ObjectRequest defines request for MetaV1 Object Request

func (*ObjectRequest) Descriptor deprecated

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

Deprecated: Use ObjectRequest.ProtoReflect.Descriptor instead.

func (*ObjectRequest) GetKey

func (x *ObjectRequest) GetKey() string

func (*ObjectRequest) ProtoMessage

func (*ObjectRequest) ProtoMessage()

func (*ObjectRequest) ProtoReflect

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

func (*ObjectRequest) Reset

func (x *ObjectRequest) Reset()

func (*ObjectRequest) String

func (x *ObjectRequest) String() string

type ObjectResponse

type ObjectResponse struct {

	// Key defines the Object Key (optionally, prefixed with global prefix)
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Revision defines the object revision
	Revision *string `protobuf:"bytes,2,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// Object defines the Object JSON Definition in AnyProto
	Object *anypb.Any `protobuf:"bytes,3,opt,name=object,proto3" json:"object,omitempty"`
	// Meta defines the Object Metadata
	Meta *ObjectResponseMeta `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

ObjectResponse defines response for MetaV1 Object

func (*ObjectResponse) Descriptor deprecated

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

Deprecated: Use ObjectResponse.ProtoReflect.Descriptor instead.

func (*ObjectResponse) GetKey

func (x *ObjectResponse) GetKey() string

func (*ObjectResponse) GetMeta

func (x *ObjectResponse) GetMeta() *ObjectResponseMeta

func (*ObjectResponse) GetObject

func (x *ObjectResponse) GetObject() *anypb.Any

func (*ObjectResponse) GetRevision

func (x *ObjectResponse) GetRevision() string

func (*ObjectResponse) ProtoMessage

func (*ObjectResponse) ProtoMessage()

func (*ObjectResponse) ProtoReflect

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

func (*ObjectResponse) Reset

func (x *ObjectResponse) Reset()

func (*ObjectResponse) String

func (x *ObjectResponse) String() string

type ObjectResponseMeta

type ObjectResponseMeta struct {

	// Updated defines when object has been updated last time
	Updated *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=updated,proto3" json:"updated,omitempty"`
	// Expires defines the object expiration timestamp (if TTL was set during creation)
	Expires *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

ObjectResponse defines response for MetaV1 Object Meta

func (*ObjectResponseMeta) Descriptor deprecated

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

Deprecated: Use ObjectResponseMeta.ProtoReflect.Descriptor instead.

func (*ObjectResponseMeta) GetExpires

func (x *ObjectResponseMeta) GetExpires() *timestamppb.Timestamp

func (*ObjectResponseMeta) GetUpdated

func (x *ObjectResponseMeta) GetUpdated() *timestamppb.Timestamp

func (*ObjectResponseMeta) ProtoMessage

func (*ObjectResponseMeta) ProtoMessage()

func (*ObjectResponseMeta) ProtoReflect

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

func (*ObjectResponseMeta) Reset

func (x *ObjectResponseMeta) Reset()

func (*ObjectResponseMeta) String

func (x *ObjectResponseMeta) String() string

type SetRequest

type SetRequest struct {

	// Key defines the Object Key (optionally, prefixed with global prefix)
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Revision defines the object revision. When set, precondition is verified on the Meta Store level
	Revision *string `protobuf:"bytes,2,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// Object defines the Object JSON Definition in AnyProto
	Object *anypb.Any `protobuf:"bytes,3,opt,name=object,proto3" json:"object,omitempty"`
	// TTL Defines object time-to-live. Optional
	Ttl *durationpb.Duration `protobuf:"bytes,4,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

SetRequest defines request for MetaV1 Object Set Request

func (*SetRequest) Descriptor deprecated

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

Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.

func (*SetRequest) GetKey

func (x *SetRequest) GetKey() string

func (*SetRequest) GetObject

func (x *SetRequest) GetObject() *anypb.Any

func (*SetRequest) GetRevision

func (x *SetRequest) GetRevision() string

func (*SetRequest) GetTtl

func (x *SetRequest) GetTtl() *durationpb.Duration

func (*SetRequest) ProtoMessage

func (*SetRequest) ProtoMessage()

func (*SetRequest) ProtoReflect

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

func (*SetRequest) Reset

func (x *SetRequest) Reset()

func (*SetRequest) String

func (x *SetRequest) String() string

type UnimplementedMetaV1Server

type UnimplementedMetaV1Server struct {
}

UnimplementedMetaV1Server must be embedded to have forward compatible implementations.

func (UnimplementedMetaV1Server) Delete

func (UnimplementedMetaV1Server) Get

func (UnimplementedMetaV1Server) List

func (UnimplementedMetaV1Server) Set

type UnsafeMetaV1Server

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL