storagepb

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

type BlobEvent struct {

	// The key of the blob the event is for
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The type of event that occurred
	Type BlobEventType `protobuf:"varint,2,opt,name=type,proto3,enum=nitric.proto.storage.v1.BlobEventType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type BlobEventRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Types that are assignable to Event:
	//
	//	*BlobEventRequest_BlobEvent
	Event isBlobEventRequest_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

type BlobEventRequest_BlobEvent struct {
	BlobEvent *BlobEvent `protobuf:"bytes,10,opt,name=blob_event,json=blobEvent,proto3,oneof"`
}

type BlobEventResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type BlobEventType int32

type ClientMessage struct {

	// globally unique ID of the request/response pair
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Content:
	//
	//	*ClientMessage_RegistrationRequest
	//	*ClientMessage_BlobEventResponse
	Content isClientMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type ClientMessage_BlobEventResponse struct {
	// Response to a blob event (change to a blob)
	BlobEventResponse *BlobEventResponse `protobuf:"bytes,3,opt,name=blob_event_response,json=blobEventResponse,proto3,oneof"`
}

type ClientMessage_RegistrationRequest struct {
	// Watch for changes on a bucket
	RegistrationRequest *RegistrationRequest `protobuf:"bytes,2,opt,name=registration_request,json=registrationRequest,proto3,oneof"`
}

type RegistrationRequest struct {

	// Name of the bucket to watch
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Event type to listen for
	BlobEventType BlobEventType `` /* 146-byte string literal not displayed */
	// A blob key prefix to filter events by
	KeyPrefixFilter string `protobuf:"bytes,3,opt,name=key_prefix_filter,json=keyPrefixFilter,proto3" json:"key_prefix_filter,omitempty"`
	// contains filtered or unexported fields
}

type RegistrationResponse struct {

	// The ID of the registration
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type ServerMessage struct {

	// globally unique ID of the request/response pair
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Content:
	//
	//	*ServerMessage_RegistrationResponse
	//	*ServerMessage_BlobEventRequest
	Content isServerMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type ServerMessage_BlobEventRequest struct {
	// Event for a blob in a bucket
	BlobEventRequest *BlobEventRequest `protobuf:"bytes,3,opt,name=blob_event_request,json=blobEventRequest,proto3,oneof"`
}

type ServerMessage_RegistrationResponse struct {
	// Watch for changes on a bucket
	RegistrationResponse *RegistrationResponse `protobuf:"bytes,2,opt,name=registration_response,json=registrationResponse,proto3,oneof"`
}

type StorageClient interface {
	// Retrieve an item from a bucket
	Read(ctx context.Context, in *StorageReadRequest, opts ...grpc.CallOption) (*StorageReadResponse, error)
	// Store an item to a bucket
	Write(ctx context.Context, in *StorageWriteRequest, opts ...grpc.CallOption) (*StorageWriteResponse, error)
	// Delete an item from a bucket
	Delete(ctx context.Context, in *StorageDeleteRequest, opts ...grpc.CallOption) (*StorageDeleteResponse, error)
	// Generate a pre-signed URL for direct operations on an item
	PreSignUrl(ctx context.Context, in *StoragePreSignUrlRequest, opts ...grpc.CallOption) (*StoragePreSignUrlResponse, error)
	// List blobs currently in the bucket
	ListBlobs(ctx context.Context, in *StorageListBlobsRequest, opts ...grpc.CallOption) (*StorageListBlobsResponse, error)
	// Determine is an object exists in a bucket
	Exists(ctx context.Context, in *StorageExistsRequest, opts ...grpc.CallOption) (*StorageExistsResponse, error)
}

type StorageDeleteRequest struct {

	// Name of the bucket to delete from
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Key of item to delete
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

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

type StorageExistsRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Key of item to retrieve
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type StorageExistsResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

type StorageListBlobsRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	Prefix     string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

type StorageListBlobsResponse struct {

	// keys of the blobs in the bucket
	Blobs []*Blob `protobuf:"bytes,1,rep,name=blobs,proto3" json:"blobs,omitempty"`
	// contains filtered or unexported fields
}

type StorageListenerClient interface {
	// Listen for changes on a bucket
	Listen(ctx context.Context, opts ...grpc.CallOption) (StorageListener_ListenClient, error)
}

type StorageListenerServer interface {
	// Listen for changes on a bucket
	Listen(StorageListener_ListenServer) error
}

type StorageListener_ListenClient interface {
	Send(*ClientMessage) error
	Recv() (*ServerMessage, error)
	grpc.ClientStream
}

type StorageListener_ListenServer interface {
	Send(*ServerMessage) error
	Recv() (*ClientMessage, error)
	grpc.ServerStream
}

type StoragePreSignUrlRequest struct {

	// Nitric name of the bucket to retrieve from
	//
	//	this will be automatically resolved to the provider specific bucket identifier.
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Key of item to generate the signed URL for.
	// The URL and the token it contains will only be valid for operations on this resource specifically.
	Key       string                             `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Operation StoragePreSignUrlRequest_Operation `` /* 136-byte string literal not displayed */
	// Expiry defined as as protobuf duration
	Expiry *durationpb.Duration `protobuf:"bytes,4,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// contains filtered or unexported fields
}

type StoragePreSignUrlRequest_Operation int32

type StoragePreSignUrlResponse struct {

	// The pre-signed url, restricted to the operation, resource and expiry time specified in the request.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

type StorageReadRequest struct {

	// Nitric name of the bucket to retrieve from
	//
	//	this will be automatically resolved to the provider specific bucket identifier.
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Key of item to retrieve
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type StorageReadResponse struct {

	// The body bytes of the retrieved storage item
	Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type StorageServer interface {
	// Retrieve an item from a bucket
	Read(context.Context, *StorageReadRequest) (*StorageReadResponse, error)
	// Store an item to a bucket
	Write(context.Context, *StorageWriteRequest) (*StorageWriteResponse, error)
	// Delete an item from a bucket
	Delete(context.Context, *StorageDeleteRequest) (*StorageDeleteResponse, error)
	// Generate a pre-signed URL for direct operations on an item
	PreSignUrl(context.Context, *StoragePreSignUrlRequest) (*StoragePreSignUrlResponse, error)
	// List blobs currently in the bucket
	ListBlobs(context.Context, *StorageListBlobsRequest) (*StorageListBlobsResponse, error)
	// Determine is an object exists in a bucket
	Exists(context.Context, *StorageExistsRequest) (*StorageExistsResponse, error)
}

type StorageWriteRequest struct {

	// Nitric name of the bucket to store in
	//
	//	this will be automatically resolved to the provider specific bucket identifier.
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Key to store the item under
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// bytes array to store
	Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

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

type UnimplementedStorageListenerServer struct {
}

type UnimplementedStorageServer struct {
}

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

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