definition

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
}

type ListResponseChunk struct {

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

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) (grpc.ServerStreamingClient[ListResponseChunk], error)
}

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, grpc.ServerStreamingServer[ListResponseChunk]) error
	// contains filtered or unexported methods
}

type MetaV1_ListClient = grpc.ServerStreamingClient[ListResponseChunk]

type MetaV1_ListServer = grpc.ServerStreamingServer[ListResponseChunk]

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
}

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
}

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
}

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
}

type UnimplementedMetaV1Server struct{}

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