cacheservice

type CacheServiceClient interface {
	// Retrieves cached data by key.
	Get(ctx context.Context, in *GetCacheRequest, opts ...grpc.CallOption) (*GetCacheResponse, error)
	// Stores or updates cached data by key.
	Put(ctx context.Context, in *PutCacheRequest, opts ...grpc.CallOption) (*PutCacheResponse, error)
	// Deletes cached data by key.
	Delete(ctx context.Context, in *DeleteCacheRequest, opts ...grpc.CallOption) (*DeleteCacheResponse, error)
	// Get or extend a reservation for a cache key
	GetOrExtendReservation(ctx context.Context, in *GetOrExtendReservationRequest, opts ...grpc.CallOption) (*GetOrExtendReservationResponse, error)
	// Release the reservation for a cache key
	ReleaseReservation(ctx context.Context, in *ReleaseReservationRequest, opts ...grpc.CallOption) (*ReleaseReservationResponse, error)
}

type CacheServiceServer interface {
	// Retrieves cached data by key.
	Get(context.Context, *GetCacheRequest) (*GetCacheResponse, error)
	// Stores or updates cached data by key.
	Put(context.Context, *PutCacheRequest) (*PutCacheResponse, error)
	// Deletes cached data by key.
	Delete(context.Context, *DeleteCacheRequest) (*DeleteCacheResponse, error)
	// Get or extend a reservation for a cache key
	GetOrExtendReservation(context.Context, *GetOrExtendReservationRequest) (*GetOrExtendReservationResponse, error)
	// Release the reservation for a cache key
	ReleaseReservation(context.Context, *ReleaseReservationRequest) (*ReleaseReservationResponse, error)
}

type CachedOutput struct {

	// Types that are assignable to Output:
	//
	//	*CachedOutput_OutputLiterals
	//	*CachedOutput_OutputUri
	Output   isCachedOutput_Output `protobuf_oneof:"output"`
	Metadata *Metadata             `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // Associated metadata
	// contains filtered or unexported fields
}

type CachedOutput_OutputLiterals struct {
	OutputLiterals *core.LiteralMap `protobuf:"bytes,1,opt,name=output_literals,json=outputLiterals,proto3,oneof"` // Output literals
}

type CachedOutput_OutputUri struct {
	OutputUri string `protobuf:"bytes,2,opt,name=output_uri,json=outputUri,proto3,oneof"` // URI to output data
}

type DeleteCacheRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Cache key
	// contains filtered or unexported fields
}

type DeleteCacheResponse struct {
	// contains filtered or unexported fields
}

type GetCacheRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Cache key
	// contains filtered or unexported fields
}

type GetCacheResponse struct {
	Output *CachedOutput `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"` // Cached output
	// contains filtered or unexported fields
}

type GetOrExtendReservationRequest struct {
	Key               string               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`                                                      // The unique ID for the reservation - same as the cache key
	OwnerId           string               `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`                               // The unique ID of the owner for the reservation
	HeartbeatInterval *durationpb.Duration `protobuf:"bytes,3,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"` // Requested reservation extension heartbeat interval
	// contains filtered or unexported fields
}

type GetOrExtendReservationResponse struct {
	Reservation *Reservation `protobuf:"bytes,1,opt,name=reservation,proto3" json:"reservation,omitempty"` // The reservation that was created or extended
	// contains filtered or unexported fields
}

type KeyMapMetadata struct {
	Values map[string]string `` // Additional metadata as key-value pairs
	/* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Metadata struct {
	SourceIdentifier *core.Identifier       `protobuf:"bytes,1,opt,name=source_identifier,json=sourceIdentifier,proto3" json:"source_identifier,omitempty"` // Source task or workflow identifier
	KeyMap           *KeyMapMetadata        `protobuf:"bytes,2,opt,name=key_map,json=keyMap,proto3" json:"key_map,omitempty"`                               // Additional metadata as key-value pairs
	CreatedAt        *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`                      // Creation timestamp
	LastUpdatedAt    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_updated_at,json=lastUpdatedAt,proto3" json:"last_updated_at,omitempty"`        // Last update timestamp
	// contains filtered or unexported fields
}

type PutCacheRequest struct {
	Key       string        `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`              // Cache key
	Output    *CachedOutput `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`        // Output to cache
	Overwrite bool          `protobuf:"varint,3,opt,name=overwrite,proto3" json:"overwrite,omitempty"` // Overwrite flag
	// contains filtered or unexported fields
}

type PutCacheResponse struct {
	// contains filtered or unexported fields
}

type ReleaseReservationRequest struct {
	Key     string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`                        // The unique ID for the reservation - same as the cache key
	OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"` // The unique ID of the owner for the reservation
	// contains filtered or unexported fields
}

type ReleaseReservationResponse struct {
	// contains filtered or unexported fields
}

type Reservation struct {
	Key               string                 `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`                                                      // The unique ID for the reservation - same as the cache key
	OwnerId           string                 `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`                               // The unique ID of the owner for the reservation
	HeartbeatInterval *durationpb.Duration   `protobuf:"bytes,3,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"` // Requested reservation extension heartbeat interval
	ExpiresAt         *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`                         // Expiration timestamp of this reservation
	// contains filtered or unexported fields
}

type UnimplementedCacheServiceServer struct {
}

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