v1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	IdType_name = map[int32]string{
		0: "ID_TYPE_UNSPECIFIED",
		1: "ID_TYPE_UUID",
		2: "ID_TYPE_PATH",
	}
	IdType_value = map[string]int32{
		"ID_TYPE_UNSPECIFIED": 0,
		"ID_TYPE_UUID":        1,
		"ID_TYPE_PATH":        2,
	}
)

Enum value maps for IdType.

View Source 
var (
	LocationType_name = map[int32]string{
		0: "LOCATION_TYPE_UNSPECIFIED",
		1: "LOCATION_TYPE_S3",
		2: "LOCATION_TYPE_FILE",
	}
	LocationType_value = map[string]int32{
		"LOCATION_TYPE_UNSPECIFIED": 0,
		"LOCATION_TYPE_S3":          1,
		"LOCATION_TYPE_FILE":        2,
	}
)

Enum value maps for LocationType.

View Source 
var File_aruna_api_internal_v1_authorize_proto protoreflect.FileDescriptor
View Source 
var File_aruna_api_internal_v1_notification_proto protoreflect.FileDescriptor
View Source 
var File_aruna_api_internal_v1_proxy_proto protoreflect.FileDescriptor
View Source 
var InternalAuthorizeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.internal.v1.InternalAuthorizeService",
	HandlerType: (*InternalAuthorizeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Authorize",
			Handler:    _InternalAuthorizeService_Authorize_Handler,
		},
		{
			MethodName: "GetSecret",
			Handler:    _InternalAuthorizeService_GetSecret_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aruna/api/internal/v1/authorize.proto",
}

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

View Source 
var InternalEventEmitterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.internal.v1.InternalEventEmitterService",
	HandlerType: (*InternalEventEmitterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "EmitEvent",
			Handler:    _InternalEventEmitterService_EmitEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aruna/api/internal/v1/notification.proto",
}

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

View Source 
var InternalEventService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.internal.v1.InternalEventService",
	HandlerType: (*InternalEventServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateStreamGroup",
			Handler:    _InternalEventService_CreateStreamGroup_Handler,
		},
		{
			MethodName: "GetStreamGroup",
			Handler:    _InternalEventService_GetStreamGroup_Handler,
		},
		{
			MethodName: "DeleteStreamGroup",
			Handler:    _InternalEventService_DeleteStreamGroup_Handler,
		},
		{
			MethodName: "GetSharedRevision",
			Handler:    _InternalEventService_GetSharedRevision_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aruna/api/internal/v1/notification.proto",
}

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

View Source 
var InternalProxyNotifierService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.internal.v1.InternalProxyNotifierService",
	HandlerType: (*InternalProxyNotifierServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOrCreateObjectByPath",
			Handler:    _InternalProxyNotifierService_GetOrCreateObjectByPath_Handler,
		},
		{
			MethodName: "FinalizeObject",
			Handler:    _InternalProxyNotifierService_FinalizeObject_Handler,
		},
		{
			MethodName: "GetOrCreateEncryptionKey",
			Handler:    _InternalProxyNotifierService_GetOrCreateEncryptionKey_Handler,
		},
		{
			MethodName: "GetObjectLocation",
			Handler:    _InternalProxyNotifierService_GetObjectLocation_Handler,
		},
		{
			MethodName: "GetCollectionByBucket",
			Handler:    _InternalProxyNotifierService_GetCollectionByBucket_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aruna/api/internal/v1/proxy.proto",
}

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

View Source 
var InternalProxyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.internal.v1.InternalProxyService",
	HandlerType: (*InternalProxyServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InitMultipartUpload",
			Handler:    _InternalProxyService_InitMultipartUpload_Handler,
		},
		{
			MethodName: "FinishMultipartUpload",
			Handler:    _InternalProxyService_FinishMultipartUpload_Handler,
		},
		{
			MethodName: "DeleteObject",
			Handler:    _InternalProxyService_DeleteObject_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aruna/api/internal/v1/proxy.proto",
}

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

Functions

func RegisterInternalAuthorizeServiceServer added in v0.5.0 

func RegisterInternalAuthorizeServiceServer(s grpc.ServiceRegistrar, srv InternalAuthorizeServiceServer)

func RegisterInternalEventEmitterServiceServer added in v0.5.0 

func RegisterInternalEventEmitterServiceServer(s grpc.ServiceRegistrar, srv InternalEventEmitterServiceServer)

func RegisterInternalEventServiceServer added in v0.5.0 

func RegisterInternalEventServiceServer(s grpc.ServiceRegistrar, srv InternalEventServiceServer)

func RegisterInternalProxyNotifierServiceServer added in v1.0.0 

func RegisterInternalProxyNotifierServiceServer(s grpc.ServiceRegistrar, srv InternalProxyNotifierServiceServer)

func RegisterInternalProxyServiceServer 

func RegisterInternalProxyServiceServer(s grpc.ServiceRegistrar, srv InternalProxyServiceServer)

Types

type Authorization added in v0.5.0 

type Authorization struct {

	// Should include the APItoken
	Secretkey string `protobuf:"bytes,1,opt,name=secretkey,proto3" json:"secretkey,omitempty"`
	// Is the API-Token ID
	Accesskey string `protobuf:"bytes,2,opt,name=accesskey,proto3" json:"accesskey,omitempty"`
	// contains filtered or unexported fields
}

func (*Authorization) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Authorization.ProtoReflect.Descriptor instead.

func (*Authorization) GetAccesskey added in v0.5.0 

func (x *Authorization) GetAccesskey() string

func (*Authorization) GetSecretkey added in v0.5.0 

func (x *Authorization) GetSecretkey() string

func (*Authorization) ProtoMessage added in v0.5.0 

func (*Authorization) ProtoMessage()

func (*Authorization) ProtoReflect added in v0.5.0 

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

func (*Authorization) Reset added in v0.5.0 

func (x *Authorization) Reset()

func (*Authorization) String added in v0.5.0 

func (x *Authorization) String() string

type AuthorizeRequest added in v0.5.0 

type AuthorizeRequest struct {

	// The resource type
	Resource v1.ResourceType `protobuf:"varint,1,opt,name=resource,proto3,enum=aruna.api.storage.models.v1.ResourceType" json:"resource,omitempty"`
	// Id of the resource (PATH / OBJECT UUID)
	Identifier *Identifier `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// Which action should be performed (CRUD)
	ResourceAction v1.ResourceAction `` /* 152-byte string literal not displayed */
	// Authorization
	Authorization *Authorization `protobuf:"bytes,4,opt,name=authorization,proto3" json:"authorization,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthorizeRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use AuthorizeRequest.ProtoReflect.Descriptor instead.

func (*AuthorizeRequest) GetAuthorization added in v1.0.0 

func (x *AuthorizeRequest) GetAuthorization() *Authorization

func (*AuthorizeRequest) GetIdentifier added in v1.0.0 

func (x *AuthorizeRequest) GetIdentifier() *Identifier

func (*AuthorizeRequest) GetResource added in v0.5.0 

func (x *AuthorizeRequest) GetResource() v1.ResourceType

func (*AuthorizeRequest) GetResourceAction added in v0.5.0 

func (x *AuthorizeRequest) GetResourceAction() v1.ResourceAction

func (*AuthorizeRequest) ProtoMessage added in v0.5.0 

func (*AuthorizeRequest) ProtoMessage()

func (*AuthorizeRequest) ProtoReflect added in v0.5.0 

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

func (*AuthorizeRequest) Reset added in v0.5.0 

func (x *AuthorizeRequest) Reset()

func (*AuthorizeRequest) String added in v0.5.0 

func (x *AuthorizeRequest) String() string

type AuthorizeResponse added in v0.5.0 

type AuthorizeResponse struct {

	// Ok -> Authorization granted, empty or not ok -> dismiss
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthorizeResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use AuthorizeResponse.ProtoReflect.Descriptor instead.

func (*AuthorizeResponse) GetOk added in v0.5.0 

func (x *AuthorizeResponse) GetOk() bool

func (*AuthorizeResponse) ProtoMessage added in v0.5.0 

func (*AuthorizeResponse) ProtoMessage()

func (*AuthorizeResponse) ProtoReflect added in v0.5.0 

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

func (*AuthorizeResponse) Reset added in v0.5.0 

func (x *AuthorizeResponse) Reset()

func (*AuthorizeResponse) String added in v0.5.0 

func (x *AuthorizeResponse) String() string

type CollectionResource added in v1.0.0 

type CollectionResource struct {
	ProjectId    string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	CollectionId string `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionResource) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use CollectionResource.ProtoReflect.Descriptor instead.

func (*CollectionResource) GetCollectionId added in v1.0.0 

func (x *CollectionResource) GetCollectionId() string

func (*CollectionResource) GetProjectId added in v1.0.0 

func (x *CollectionResource) GetProjectId() string

func (*CollectionResource) ProtoMessage added in v1.0.0 

func (*CollectionResource) ProtoMessage()

func (*CollectionResource) ProtoReflect added in v1.0.0 

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

func (*CollectionResource) Reset added in v1.0.0 

func (x *CollectionResource) Reset()

func (*CollectionResource) String added in v1.0.0 

func (x *CollectionResource) String() string

type CreateStreamGroupRequest added in v0.5.0 

type CreateStreamGroupRequest struct {

	// Authorization for the user who wants to create this stream group
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// Event type
	EventType v11.EventType `` /* 139-byte string literal not displayed */
	// Type of the resource (Collection, Object etc.)
	ResourceType v1.ResourceType `` /* 144-byte string literal not displayed */
	// Resource ID
	ResourceId string `protobuf:"bytes,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// Should all "sub" resources be included
	NotifyOnSubResource bool `protobuf:"varint,5,opt,name=notify_on_sub_resource,json=notifyOnSubResource,proto3" json:"notify_on_sub_resource,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStreamGroupRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use CreateStreamGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateStreamGroupRequest) GetEventType added in v0.5.0 

func (x *CreateStreamGroupRequest) GetEventType() v11.EventType

func (*CreateStreamGroupRequest) GetNotifyOnSubResource added in v0.5.0 

func (x *CreateStreamGroupRequest) GetNotifyOnSubResource() bool

func (*CreateStreamGroupRequest) GetResourceId added in v0.5.0 

func (x *CreateStreamGroupRequest) GetResourceId() string

func (*CreateStreamGroupRequest) GetResourceType added in v0.5.0 

func (x *CreateStreamGroupRequest) GetResourceType() v1.ResourceType

func (*CreateStreamGroupRequest) GetToken added in v0.5.0 

func (x *CreateStreamGroupRequest) GetToken() string

func (*CreateStreamGroupRequest) ProtoMessage added in v0.5.0 

func (*CreateStreamGroupRequest) ProtoMessage()

func (*CreateStreamGroupRequest) ProtoReflect added in v0.5.0 

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

func (*CreateStreamGroupRequest) Reset added in v0.5.0 

func (x *CreateStreamGroupRequest) Reset()

func (*CreateStreamGroupRequest) String added in v0.5.0 

func (x *CreateStreamGroupRequest) String() string

type CreateStreamGroupResponse added in v0.5.0 

type CreateStreamGroupResponse struct {

	// The stream_group
	StreamGroup *StreamGroup `protobuf:"bytes,1,opt,name=stream_group,json=streamGroup,proto3" json:"stream_group,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStreamGroupResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use CreateStreamGroupResponse.ProtoReflect.Descriptor instead.

func (*CreateStreamGroupResponse) GetStreamGroup added in v0.5.0 

func (x *CreateStreamGroupResponse) GetStreamGroup() *StreamGroup

func (*CreateStreamGroupResponse) ProtoMessage added in v0.5.0 

func (*CreateStreamGroupResponse) ProtoMessage()

func (*CreateStreamGroupResponse) ProtoReflect added in v0.5.0 

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

func (*CreateStreamGroupResponse) Reset added in v0.5.0 

func (x *CreateStreamGroupResponse) Reset()

func (*CreateStreamGroupResponse) String added in v0.5.0 

func (x *CreateStreamGroupResponse) String() string

type DeleteObjectRequest added in v1.0.0 

type DeleteObjectRequest struct {
	Location *Location `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteObjectRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use DeleteObjectRequest.ProtoReflect.Descriptor instead.

func (*DeleteObjectRequest) GetLocation added in v1.0.0 

func (x *DeleteObjectRequest) GetLocation() *Location

func (*DeleteObjectRequest) ProtoMessage added in v1.0.0 

func (*DeleteObjectRequest) ProtoMessage()

func (*DeleteObjectRequest) ProtoReflect added in v1.0.0 

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

func (*DeleteObjectRequest) Reset added in v1.0.0 

func (x *DeleteObjectRequest) Reset()

func (*DeleteObjectRequest) String added in v1.0.0 

func (x *DeleteObjectRequest) String() string

type DeleteObjectResponse added in v1.0.0 

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

func (*DeleteObjectResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use DeleteObjectResponse.ProtoReflect.Descriptor instead.

func (*DeleteObjectResponse) ProtoMessage added in v1.0.0 

func (*DeleteObjectResponse) ProtoMessage()

func (*DeleteObjectResponse) ProtoReflect added in v1.0.0 

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

func (*DeleteObjectResponse) Reset added in v1.0.0 

func (x *DeleteObjectResponse) Reset()

func (*DeleteObjectResponse) String added in v1.0.0 

func (x *DeleteObjectResponse) String() string

type DeleteStreamGroupRequest added in v0.5.0 

type DeleteStreamGroupRequest struct {

	// User token
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// Stream group ID
	StreamGroupId string `protobuf:"bytes,2,opt,name=stream_group_id,json=streamGroupId,proto3" json:"stream_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStreamGroupRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use DeleteStreamGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteStreamGroupRequest) GetStreamGroupId added in v0.5.0 

func (x *DeleteStreamGroupRequest) GetStreamGroupId() string

func (*DeleteStreamGroupRequest) GetToken added in v0.5.0 

func (x *DeleteStreamGroupRequest) GetToken() string

func (*DeleteStreamGroupRequest) ProtoMessage added in v0.5.0 

func (*DeleteStreamGroupRequest) ProtoMessage()

func (*DeleteStreamGroupRequest) ProtoReflect added in v0.5.0 

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

func (*DeleteStreamGroupRequest) Reset added in v0.5.0 

func (x *DeleteStreamGroupRequest) Reset()

func (*DeleteStreamGroupRequest) String added in v0.5.0 

func (x *DeleteStreamGroupRequest) String() string

type DeleteStreamGroupResponse added in v0.5.0 

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

func (*DeleteStreamGroupResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use DeleteStreamGroupResponse.ProtoReflect.Descriptor instead.

func (*DeleteStreamGroupResponse) ProtoMessage added in v0.5.0 

func (*DeleteStreamGroupResponse) ProtoMessage()

func (*DeleteStreamGroupResponse) ProtoReflect added in v0.5.0 

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

func (*DeleteStreamGroupResponse) Reset added in v0.5.0 

func (x *DeleteStreamGroupResponse) Reset()

func (*DeleteStreamGroupResponse) String added in v0.5.0 

func (x *DeleteStreamGroupResponse) String() string

type EmitEventRequest added in v0.5.0 

type EmitEventRequest struct {

	// The resource Type e.g. Collection / Object etc.
	EventResource v1.ResourceType `` /* 147-byte string literal not displayed */
	// The resource ID
	ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// Event type (CRUD)
	EventType v11.EventType `` /* 139-byte string literal not displayed */
	// All relations of the resource, only parents are shown
	Resources []*EmittedResource `protobuf:"bytes,4,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*EmitEventRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use EmitEventRequest.ProtoReflect.Descriptor instead.

func (*EmitEventRequest) GetEventResource added in v0.5.0 

func (x *EmitEventRequest) GetEventResource() v1.ResourceType

func (*EmitEventRequest) GetEventType added in v0.5.0 

func (x *EmitEventRequest) GetEventType() v11.EventType

func (*EmitEventRequest) GetResourceId added in v0.5.0 

func (x *EmitEventRequest) GetResourceId() string

func (*EmitEventRequest) GetResources added in v1.0.0 

func (x *EmitEventRequest) GetResources() []*EmittedResource

func (*EmitEventRequest) ProtoMessage added in v0.5.0 

func (*EmitEventRequest) ProtoMessage()

func (*EmitEventRequest) ProtoReflect added in v0.5.0 

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

func (*EmitEventRequest) Reset added in v0.5.0 

func (x *EmitEventRequest) Reset()

func (*EmitEventRequest) String added in v0.5.0 

func (x *EmitEventRequest) String() string

type EmitEventResponse added in v0.5.0 

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

func (*EmitEventResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use EmitEventResponse.ProtoReflect.Descriptor instead.

func (*EmitEventResponse) ProtoMessage added in v0.5.0 

func (*EmitEventResponse) ProtoMessage()

func (*EmitEventResponse) ProtoReflect added in v0.5.0 

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

func (*EmitEventResponse) Reset added in v0.5.0 

func (x *EmitEventResponse) Reset()

func (*EmitEventResponse) String added in v0.5.0 

func (x *EmitEventResponse) String() string

type EmittedResource added in v1.0.0 

type EmittedResource struct {

	// Types that are assignable to Resource:
	//	*EmittedResource_Project
	//	*EmittedResource_Collection
	//	*EmittedResource_Object
	//	*EmittedResource_ObjectGroup
	Resource isEmittedResource_Resource `protobuf_oneof:"resource"`
	// contains filtered or unexported fields
}

func (*EmittedResource) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use EmittedResource.ProtoReflect.Descriptor instead.

func (*EmittedResource) GetCollection added in v1.0.0 

func (x *EmittedResource) GetCollection() *CollectionResource

func (*EmittedResource) GetObject added in v1.0.0 

func (x *EmittedResource) GetObject() *ObjectResource

func (*EmittedResource) GetObjectGroup added in v1.0.0 

func (x *EmittedResource) GetObjectGroup() *ObjectGroupResource

func (*EmittedResource) GetProject added in v1.0.0 

func (x *EmittedResource) GetProject() *ProjectResource

func (*EmittedResource) GetResource added in v1.0.0 

func (m *EmittedResource) GetResource() isEmittedResource_Resource

func (*EmittedResource) ProtoMessage added in v1.0.0 

func (*EmittedResource) ProtoMessage()

func (*EmittedResource) ProtoReflect added in v1.0.0 

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

func (*EmittedResource) Reset added in v1.0.0 

func (x *EmittedResource) Reset()

func (*EmittedResource) String added in v1.0.0 

func (x *EmittedResource) String() string

type EmittedResource_Collection added in v1.0.0 

type EmittedResource_Collection struct {
	Collection *CollectionResource `protobuf:"bytes,2,opt,name=collection,proto3,oneof"`
}

type EmittedResource_Object added in v1.0.0 

type EmittedResource_Object struct {
	Object *ObjectResource `protobuf:"bytes,3,opt,name=object,proto3,oneof"`
}

type EmittedResource_ObjectGroup added in v1.0.0 

type EmittedResource_ObjectGroup struct {
	ObjectGroup *ObjectGroupResource `protobuf:"bytes,4,opt,name=object_group,json=objectGroup,proto3,oneof"`
}

type EmittedResource_Project added in v1.0.0 

type EmittedResource_Project struct {
	Project *ProjectResource `protobuf:"bytes,1,opt,name=project,proto3,oneof"`
}

type FinalizeObjectRequest added in v1.0.0 

type FinalizeObjectRequest struct {
	ObjectId      string     `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`             // This should be stored temporarily
	CollectionId  string     `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"` // This should be stored temporarily
	Location      *Location  `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`                             // This will be the final location of the object
	Hashes        []*v1.Hash `protobuf:"bytes,4,rep,name=hashes,proto3" json:"hashes,omitempty"`
	ContentLength int64      `protobuf:"varint,5,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// contains filtered or unexported fields
}

func (*FinalizeObjectRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use FinalizeObjectRequest.ProtoReflect.Descriptor instead.

func (*FinalizeObjectRequest) GetCollectionId added in v1.0.0 

func (x *FinalizeObjectRequest) GetCollectionId() string

func (*FinalizeObjectRequest) GetContentLength added in v1.0.0 

func (x *FinalizeObjectRequest) GetContentLength() int64

func (*FinalizeObjectRequest) GetHashes added in v1.0.0 

func (x *FinalizeObjectRequest) GetHashes() []*v1.Hash

func (*FinalizeObjectRequest) GetLocation added in v1.0.0 

func (x *FinalizeObjectRequest) GetLocation() *Location

func (*FinalizeObjectRequest) GetObjectId added in v1.0.0 

func (x *FinalizeObjectRequest) GetObjectId() string

func (*FinalizeObjectRequest) ProtoMessage added in v1.0.0 

func (*FinalizeObjectRequest) ProtoMessage()

func (*FinalizeObjectRequest) ProtoReflect added in v1.0.0 

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

func (*FinalizeObjectRequest) Reset added in v1.0.0 

func (x *FinalizeObjectRequest) Reset()

func (*FinalizeObjectRequest) String added in v1.0.0 

func (x *FinalizeObjectRequest) String() string

type FinalizeObjectResponse added in v1.0.0 

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

func (*FinalizeObjectResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use FinalizeObjectResponse.ProtoReflect.Descriptor instead.

func (*FinalizeObjectResponse) ProtoMessage added in v1.0.0 

func (*FinalizeObjectResponse) ProtoMessage()

func (*FinalizeObjectResponse) ProtoReflect added in v1.0.0 

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

func (*FinalizeObjectResponse) Reset added in v1.0.0 

func (x *FinalizeObjectResponse) Reset()

func (*FinalizeObjectResponse) String added in v1.0.0 

func (x *FinalizeObjectResponse) String() string

type FinishMultipartUploadRequest added in v1.0.0 

type FinishMultipartUploadRequest struct {
	UploadId     string      `protobuf:"bytes,1,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"`
	Path         string      `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	ObjectId     string      `protobuf:"bytes,3,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	CollectionId string      `protobuf:"bytes,4,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	PartEtags    []*PartETag `protobuf:"bytes,5,rep,name=part_etags,json=partEtags,proto3" json:"part_etags,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishMultipartUploadRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use FinishMultipartUploadRequest.ProtoReflect.Descriptor instead.

func (*FinishMultipartUploadRequest) GetCollectionId added in v1.0.0 

func (x *FinishMultipartUploadRequest) GetCollectionId() string

func (*FinishMultipartUploadRequest) GetObjectId added in v1.0.0 

func (x *FinishMultipartUploadRequest) GetObjectId() string

func (*FinishMultipartUploadRequest) GetPartEtags added in v1.0.0 

func (x *FinishMultipartUploadRequest) GetPartEtags() []*PartETag

func (*FinishMultipartUploadRequest) GetPath added in v1.0.0 

func (x *FinishMultipartUploadRequest) GetPath() string

func (*FinishMultipartUploadRequest) GetUploadId added in v1.0.0 

func (x *FinishMultipartUploadRequest) GetUploadId() string

func (*FinishMultipartUploadRequest) ProtoMessage added in v1.0.0 

func (*FinishMultipartUploadRequest) ProtoMessage()

func (*FinishMultipartUploadRequest) ProtoReflect added in v1.0.0 

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

func (*FinishMultipartUploadRequest) Reset added in v1.0.0 

func (x *FinishMultipartUploadRequest) Reset()

func (*FinishMultipartUploadRequest) String added in v1.0.0 

func (x *FinishMultipartUploadRequest) String() string

type FinishMultipartUploadResponse added in v1.0.0 

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

func (*FinishMultipartUploadResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use FinishMultipartUploadResponse.ProtoReflect.Descriptor instead.

func (*FinishMultipartUploadResponse) ProtoMessage added in v1.0.0 

func (*FinishMultipartUploadResponse) ProtoMessage()

func (*FinishMultipartUploadResponse) ProtoReflect added in v1.0.0 

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

func (*FinishMultipartUploadResponse) Reset added in v1.0.0 

func (x *FinishMultipartUploadResponse) Reset()

func (*FinishMultipartUploadResponse) String added in v1.0.0 

func (x *FinishMultipartUploadResponse) String() string

type GetCollectionByBucketRequest added in v1.0.0 

type GetCollectionByBucketRequest struct {
	Bucket    string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	AccessKey string `protobuf:"bytes,2,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCollectionByBucketRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetCollectionByBucketRequest.ProtoReflect.Descriptor instead.

func (*GetCollectionByBucketRequest) GetAccessKey added in v1.0.0 

func (x *GetCollectionByBucketRequest) GetAccessKey() string

func (*GetCollectionByBucketRequest) GetBucket added in v1.0.0 

func (x *GetCollectionByBucketRequest) GetBucket() string

func (*GetCollectionByBucketRequest) ProtoMessage added in v1.0.0 

func (*GetCollectionByBucketRequest) ProtoMessage()

func (*GetCollectionByBucketRequest) ProtoReflect added in v1.0.0 

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

func (*GetCollectionByBucketRequest) Reset added in v1.0.0 

func (x *GetCollectionByBucketRequest) Reset()

func (*GetCollectionByBucketRequest) String added in v1.0.0 

func (x *GetCollectionByBucketRequest) String() string

type GetCollectionByBucketResponse added in v1.0.0 

type GetCollectionByBucketResponse struct {
	ProjectId    string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	CollectionId string `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCollectionByBucketResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetCollectionByBucketResponse.ProtoReflect.Descriptor instead.

func (*GetCollectionByBucketResponse) GetCollectionId added in v1.0.0 

func (x *GetCollectionByBucketResponse) GetCollectionId() string

func (*GetCollectionByBucketResponse) GetProjectId added in v1.0.0 

func (x *GetCollectionByBucketResponse) GetProjectId() string

func (*GetCollectionByBucketResponse) ProtoMessage added in v1.0.0 

func (*GetCollectionByBucketResponse) ProtoMessage()

func (*GetCollectionByBucketResponse) ProtoReflect added in v1.0.0 

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

func (*GetCollectionByBucketResponse) Reset added in v1.0.0 

func (x *GetCollectionByBucketResponse) Reset()

func (*GetCollectionByBucketResponse) String added in v1.0.0 

func (x *GetCollectionByBucketResponse) String() string

type GetObjectLocationRequest added in v1.0.0 

type GetObjectLocationRequest struct {
	Path       string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	RevisionId string `protobuf:"bytes,2,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
	AccessKey  string `protobuf:"bytes,3,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	EndpointId string `protobuf:"bytes,4,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectLocationRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetObjectLocationRequest.ProtoReflect.Descriptor instead.

func (*GetObjectLocationRequest) GetAccessKey added in v1.0.0 

func (x *GetObjectLocationRequest) GetAccessKey() string

func (*GetObjectLocationRequest) GetEndpointId added in v1.0.0 

func (x *GetObjectLocationRequest) GetEndpointId() string

func (*GetObjectLocationRequest) GetPath added in v1.0.0 

func (x *GetObjectLocationRequest) GetPath() string

func (*GetObjectLocationRequest) GetRevisionId added in v1.0.0 

func (x *GetObjectLocationRequest) GetRevisionId() string

func (*GetObjectLocationRequest) ProtoMessage added in v1.0.0 

func (*GetObjectLocationRequest) ProtoMessage()

func (*GetObjectLocationRequest) ProtoReflect added in v1.0.0 

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

func (*GetObjectLocationRequest) Reset added in v1.0.0 

func (x *GetObjectLocationRequest) Reset()

func (*GetObjectLocationRequest) String added in v1.0.0 

func (x *GetObjectLocationRequest) String() string

type GetObjectLocationResponse added in v1.0.0 

type GetObjectLocationResponse struct {
	Object   *v1.Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Location *Location  `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectLocationResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetObjectLocationResponse.ProtoReflect.Descriptor instead.

func (*GetObjectLocationResponse) GetLocation added in v1.0.0 

func (x *GetObjectLocationResponse) GetLocation() *Location

func (*GetObjectLocationResponse) GetObject added in v1.0.0 

func (x *GetObjectLocationResponse) GetObject() *v1.Object

func (*GetObjectLocationResponse) ProtoMessage added in v1.0.0 

func (*GetObjectLocationResponse) ProtoMessage()

func (*GetObjectLocationResponse) ProtoReflect added in v1.0.0 

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

func (*GetObjectLocationResponse) Reset added in v1.0.0 

func (x *GetObjectLocationResponse) Reset()

func (*GetObjectLocationResponse) String added in v1.0.0 

func (x *GetObjectLocationResponse) String() string

type GetOrCreateEncryptionKeyRequest added in v1.0.0 

type GetOrCreateEncryptionKeyRequest struct {
	Path       string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Hash       string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	EndpointId string `protobuf:"bytes,3,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOrCreateEncryptionKeyRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetOrCreateEncryptionKeyRequest.ProtoReflect.Descriptor instead.

func (*GetOrCreateEncryptionKeyRequest) GetEndpointId added in v1.0.0 

func (x *GetOrCreateEncryptionKeyRequest) GetEndpointId() string

func (*GetOrCreateEncryptionKeyRequest) GetHash added in v1.0.0 

func (x *GetOrCreateEncryptionKeyRequest) GetHash() string

func (*GetOrCreateEncryptionKeyRequest) GetPath added in v1.0.0 

func (x *GetOrCreateEncryptionKeyRequest) GetPath() string

func (*GetOrCreateEncryptionKeyRequest) ProtoMessage added in v1.0.0 

func (*GetOrCreateEncryptionKeyRequest) ProtoMessage()

func (*GetOrCreateEncryptionKeyRequest) ProtoReflect added in v1.0.0 

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

func (*GetOrCreateEncryptionKeyRequest) Reset added in v1.0.0 

func (x *GetOrCreateEncryptionKeyRequest) Reset()

func (*GetOrCreateEncryptionKeyRequest) String added in v1.0.0 

func (x *GetOrCreateEncryptionKeyRequest) String() string

type GetOrCreateEncryptionKeyResponse added in v1.0.0 

type GetOrCreateEncryptionKeyResponse struct {
	EncryptionKey string `protobuf:"bytes,1,opt,name=encryption_key,json=encryptionKey,proto3" json:"encryption_key,omitempty"`
	Created       bool   `protobuf:"varint,2,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOrCreateEncryptionKeyResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetOrCreateEncryptionKeyResponse.ProtoReflect.Descriptor instead.

func (*GetOrCreateEncryptionKeyResponse) GetCreated added in v1.0.0 

func (x *GetOrCreateEncryptionKeyResponse) GetCreated() bool

func (*GetOrCreateEncryptionKeyResponse) GetEncryptionKey added in v1.0.0 

func (x *GetOrCreateEncryptionKeyResponse) GetEncryptionKey() string

func (*GetOrCreateEncryptionKeyResponse) ProtoMessage added in v1.0.0 

func (*GetOrCreateEncryptionKeyResponse) ProtoMessage()

func (*GetOrCreateEncryptionKeyResponse) ProtoReflect added in v1.0.0 

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

func (*GetOrCreateEncryptionKeyResponse) Reset added in v1.0.0 

func (x *GetOrCreateEncryptionKeyResponse) Reset()

func (*GetOrCreateEncryptionKeyResponse) String added in v1.0.0 

func (x *GetOrCreateEncryptionKeyResponse) String() string

type GetOrCreateObjectByPathRequest added in v1.0.0 

type GetOrCreateObjectByPathRequest struct {
	Path       string           `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	AccessKey  string           `protobuf:"bytes,2,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"` // Validate if the user has correct permissions
	Object     *v11.StageObject `protobuf:"bytes,3,opt,name=object,proto3" json:"object,omitempty"`                        // Will only be used if no staging object exists
	GetOnly    bool             `protobuf:"varint,4,opt,name=get_only,json=getOnly,proto3" json:"get_only,omitempty"`      // Should this only get the object NOT create -> fail
	EndpointId string           `protobuf:"bytes,5,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOrCreateObjectByPathRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetOrCreateObjectByPathRequest.ProtoReflect.Descriptor instead.

func (*GetOrCreateObjectByPathRequest) GetAccessKey added in v1.0.0 

func (x *GetOrCreateObjectByPathRequest) GetAccessKey() string

func (*GetOrCreateObjectByPathRequest) GetEndpointId added in v1.0.0 

func (x *GetOrCreateObjectByPathRequest) GetEndpointId() string

func (*GetOrCreateObjectByPathRequest) GetGetOnly added in v1.0.0 

func (x *GetOrCreateObjectByPathRequest) GetGetOnly() bool

func (*GetOrCreateObjectByPathRequest) GetObject added in v1.0.0 

func (x *GetOrCreateObjectByPathRequest) GetObject() *v11.StageObject

func (*GetOrCreateObjectByPathRequest) GetPath added in v1.0.0 

func (x *GetOrCreateObjectByPathRequest) GetPath() string

func (*GetOrCreateObjectByPathRequest) ProtoMessage added in v1.0.0 

func (*GetOrCreateObjectByPathRequest) ProtoMessage()

func (*GetOrCreateObjectByPathRequest) ProtoReflect added in v1.0.0 

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

func (*GetOrCreateObjectByPathRequest) Reset added in v1.0.0 

func (x *GetOrCreateObjectByPathRequest) Reset()

func (*GetOrCreateObjectByPathRequest) String added in v1.0.0 

func (x *GetOrCreateObjectByPathRequest) String() string

type GetOrCreateObjectByPathResponse added in v1.0.0 

type GetOrCreateObjectByPathResponse struct {
	ObjectId       string       `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	CollectionId   string       `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	Dataclass      v1.DataClass `protobuf:"varint,3,opt,name=dataclass,proto3,enum=aruna.api.storage.models.v1.DataClass" json:"dataclass,omitempty"`
	Hashes         []*v1.Hash   `protobuf:"bytes,4,rep,name=hashes,proto3" json:"hashes,omitempty"`
	RevisionNumber int64        `protobuf:"varint,5,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
	Created        bool         `protobuf:"varint,6,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOrCreateObjectByPathResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetOrCreateObjectByPathResponse.ProtoReflect.Descriptor instead.

func (*GetOrCreateObjectByPathResponse) GetCollectionId added in v1.0.0 

func (x *GetOrCreateObjectByPathResponse) GetCollectionId() string

func (*GetOrCreateObjectByPathResponse) GetCreated added in v1.0.0 

func (x *GetOrCreateObjectByPathResponse) GetCreated() bool

func (*GetOrCreateObjectByPathResponse) GetDataclass added in v1.0.0 

func (x *GetOrCreateObjectByPathResponse) GetDataclass() v1.DataClass

func (*GetOrCreateObjectByPathResponse) GetHashes added in v1.0.0 

func (x *GetOrCreateObjectByPathResponse) GetHashes() []*v1.Hash

func (*GetOrCreateObjectByPathResponse) GetObjectId added in v1.0.0 

func (x *GetOrCreateObjectByPathResponse) GetObjectId() string

func (*GetOrCreateObjectByPathResponse) GetRevisionNumber added in v1.0.0 

func (x *GetOrCreateObjectByPathResponse) GetRevisionNumber() int64

func (*GetOrCreateObjectByPathResponse) ProtoMessage added in v1.0.0 

func (*GetOrCreateObjectByPathResponse) ProtoMessage()

func (*GetOrCreateObjectByPathResponse) ProtoReflect added in v1.0.0 

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

func (*GetOrCreateObjectByPathResponse) Reset added in v1.0.0 

func (x *GetOrCreateObjectByPathResponse) Reset()

func (*GetOrCreateObjectByPathResponse) String added in v1.0.0 

func (x *GetOrCreateObjectByPathResponse) String() string

type GetSecretRequest added in v1.0.0 

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

func (*GetSecretRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetSecretRequest.ProtoReflect.Descriptor instead.

func (*GetSecretRequest) GetAccesskey added in v1.0.0 

func (x *GetSecretRequest) GetAccesskey() string

func (*GetSecretRequest) ProtoMessage added in v1.0.0 

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) ProtoReflect added in v1.0.0 

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

func (*GetSecretRequest) Reset added in v1.0.0 

func (x *GetSecretRequest) Reset()

func (*GetSecretRequest) String added in v1.0.0 

func (x *GetSecretRequest) String() string

type GetSecretResponse added in v1.0.0 

type GetSecretResponse struct {
	Authorization *Authorization `protobuf:"bytes,1,opt,name=authorization,proto3" json:"authorization,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSecretResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetSecretResponse.ProtoReflect.Descriptor instead.

func (*GetSecretResponse) GetAuthorization added in v1.0.0 

func (x *GetSecretResponse) GetAuthorization() *Authorization

func (*GetSecretResponse) ProtoMessage added in v1.0.0 

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) ProtoReflect added in v1.0.0 

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

func (*GetSecretResponse) Reset added in v1.0.0 

func (x *GetSecretResponse) Reset()

func (*GetSecretResponse) String added in v1.0.0 

func (x *GetSecretResponse) String() string

type GetSharedRevisionRequest added in v0.5.0 

type GetSharedRevisionRequest struct {

	// Resource Type (ObjectGroup or Object)
	ResourceType v1.ResourceType `` /* 144-byte string literal not displayed */
	// Resource ID
	ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSharedRevisionRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use GetSharedRevisionRequest.ProtoReflect.Descriptor instead.

func (*GetSharedRevisionRequest) GetResourceId added in v0.5.0 

func (x *GetSharedRevisionRequest) GetResourceId() string

func (*GetSharedRevisionRequest) GetResourceType added in v0.5.0 

func (x *GetSharedRevisionRequest) GetResourceType() v1.ResourceType

func (*GetSharedRevisionRequest) ProtoMessage added in v0.5.0 

func (*GetSharedRevisionRequest) ProtoMessage()

func (*GetSharedRevisionRequest) ProtoReflect added in v0.5.0 

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

func (*GetSharedRevisionRequest) Reset added in v0.5.0 

func (x *GetSharedRevisionRequest) Reset()

func (*GetSharedRevisionRequest) String added in v0.5.0 

func (x *GetSharedRevisionRequest) String() string

type GetSharedRevisionResponse added in v0.5.0 

type GetSharedRevisionResponse struct {

	// Shared revision ID
	SharedRevisionId string `protobuf:"bytes,1,opt,name=shared_revision_id,json=sharedRevisionId,proto3" json:"shared_revision_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSharedRevisionResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use GetSharedRevisionResponse.ProtoReflect.Descriptor instead.

func (*GetSharedRevisionResponse) GetSharedRevisionId added in v0.5.0 

func (x *GetSharedRevisionResponse) GetSharedRevisionId() string

func (*GetSharedRevisionResponse) ProtoMessage added in v0.5.0 

func (*GetSharedRevisionResponse) ProtoMessage()

func (*GetSharedRevisionResponse) ProtoReflect added in v0.5.0 

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

func (*GetSharedRevisionResponse) Reset added in v0.5.0 

func (x *GetSharedRevisionResponse) Reset()

func (*GetSharedRevisionResponse) String added in v0.5.0 

func (x *GetSharedRevisionResponse) String() string

type GetStreamGroupRequest added in v0.5.0 

type GetStreamGroupRequest struct {

	// User token
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// Stream group ID
	StreamGroupId string `protobuf:"bytes,2,opt,name=stream_group_id,json=streamGroupId,proto3" json:"stream_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamGroupRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use GetStreamGroupRequest.ProtoReflect.Descriptor instead.

func (*GetStreamGroupRequest) GetStreamGroupId added in v0.5.0 

func (x *GetStreamGroupRequest) GetStreamGroupId() string

func (*GetStreamGroupRequest) GetToken added in v0.5.0 

func (x *GetStreamGroupRequest) GetToken() string

func (*GetStreamGroupRequest) ProtoMessage added in v0.5.0 

func (*GetStreamGroupRequest) ProtoMessage()

func (*GetStreamGroupRequest) ProtoReflect added in v0.5.0 

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

func (*GetStreamGroupRequest) Reset added in v0.5.0 

func (x *GetStreamGroupRequest) Reset()

func (*GetStreamGroupRequest) String added in v0.5.0 

func (x *GetStreamGroupRequest) String() string

type GetStreamGroupResponse added in v0.5.0 

type GetStreamGroupResponse struct {

	// Stream group
	StreamGroup *StreamGroup `protobuf:"bytes,1,opt,name=stream_group,json=streamGroup,proto3" json:"stream_group,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamGroupResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use GetStreamGroupResponse.ProtoReflect.Descriptor instead.

func (*GetStreamGroupResponse) GetStreamGroup added in v0.5.0 

func (x *GetStreamGroupResponse) GetStreamGroup() *StreamGroup

func (*GetStreamGroupResponse) ProtoMessage added in v0.5.0 

func (*GetStreamGroupResponse) ProtoMessage()

func (*GetStreamGroupResponse) ProtoReflect added in v0.5.0 

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

func (*GetStreamGroupResponse) Reset added in v0.5.0 

func (x *GetStreamGroupResponse) Reset()

func (*GetStreamGroupResponse) String added in v0.5.0 

func (x *GetStreamGroupResponse) String() string

type IdType added in v1.0.0 

type IdType int32
const (
	IdType_ID_TYPE_UNSPECIFIED IdType = 0
	IdType_ID_TYPE_UUID        IdType = 1
	IdType_ID_TYPE_PATH        IdType = 2
)

func (IdType) Descriptor added in v1.0.0 

func (IdType) Descriptor() protoreflect.EnumDescriptor

func (IdType) Enum added in v1.0.0 

func (x IdType) Enum() *IdType

func (IdType) EnumDescriptor deprecated added in v1.0.0 

func (IdType) EnumDescriptor() ([]byte, []int)

Deprecated: Use IdType.Descriptor instead.

func (IdType) Number added in v1.0.0 

func (x IdType) Number() protoreflect.EnumNumber

func (IdType) String added in v1.0.0 

func (x IdType) String() string

func (IdType) Type added in v1.0.0 

func (IdType) Type() protoreflect.EnumType

type Identifier added in v1.0.0 

type Identifier struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Idtype IdType `protobuf:"varint,2,opt,name=idtype,proto3,enum=aruna.api.internal.v1.IdType" json:"idtype,omitempty"`
	// contains filtered or unexported fields
}

func (*Identifier) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use Identifier.ProtoReflect.Descriptor instead.

func (*Identifier) GetIdtype added in v1.0.0 

func (x *Identifier) GetIdtype() IdType

func (*Identifier) GetName added in v1.0.0 

func (x *Identifier) GetName() string

func (*Identifier) ProtoMessage added in v1.0.0 

func (*Identifier) ProtoMessage()

func (*Identifier) ProtoReflect added in v1.0.0 

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

func (*Identifier) Reset added in v1.0.0 

func (x *Identifier) Reset()

func (*Identifier) String added in v1.0.0 

func (x *Identifier) String() string

type InitMultipartUploadRequest added in v1.0.0 

type InitMultipartUploadRequest struct {
	Path         string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	ObjectId     string `protobuf:"bytes,2,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	CollectionId string `protobuf:"bytes,3,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	// contains filtered or unexported fields
}

func (*InitMultipartUploadRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use InitMultipartUploadRequest.ProtoReflect.Descriptor instead.

func (*InitMultipartUploadRequest) GetCollectionId added in v1.0.0 

func (x *InitMultipartUploadRequest) GetCollectionId() string

func (*InitMultipartUploadRequest) GetObjectId added in v1.0.0 

func (x *InitMultipartUploadRequest) GetObjectId() string

func (*InitMultipartUploadRequest) GetPath added in v1.0.0 

func (x *InitMultipartUploadRequest) GetPath() string

func (*InitMultipartUploadRequest) ProtoMessage added in v1.0.0 

func (*InitMultipartUploadRequest) ProtoMessage()

func (*InitMultipartUploadRequest) ProtoReflect added in v1.0.0 

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

func (*InitMultipartUploadRequest) Reset added in v1.0.0 

func (x *InitMultipartUploadRequest) Reset()

func (*InitMultipartUploadRequest) String added in v1.0.0 

func (x *InitMultipartUploadRequest) String() string

type InitMultipartUploadResponse added in v1.0.0 

type InitMultipartUploadResponse struct {
	UploadId string `protobuf:"bytes,1,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"`
	// contains filtered or unexported fields
}

func (*InitMultipartUploadResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use InitMultipartUploadResponse.ProtoReflect.Descriptor instead.

func (*InitMultipartUploadResponse) GetUploadId added in v1.0.0 

func (x *InitMultipartUploadResponse) GetUploadId() string

func (*InitMultipartUploadResponse) ProtoMessage added in v1.0.0 

func (*InitMultipartUploadResponse) ProtoMessage()

func (*InitMultipartUploadResponse) ProtoReflect added in v1.0.0 

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

func (*InitMultipartUploadResponse) Reset added in v1.0.0 

func (x *InitMultipartUploadResponse) Reset()

func (*InitMultipartUploadResponse) String added in v1.0.0 

func (x *InitMultipartUploadResponse) String() string

type InternalAuthorizeServiceClient added in v0.5.0 

type InternalAuthorizeServiceClient interface {
	Authorize(ctx context.Context, in *AuthorizeRequest, opts ...grpc.CallOption) (*AuthorizeResponse, error)
	GetSecret(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)
}

InternalAuthorizeServiceClient is the client API for InternalAuthorizeService 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 NewInternalAuthorizeServiceClient added in v0.5.0 

func NewInternalAuthorizeServiceClient(cc grpc.ClientConnInterface) InternalAuthorizeServiceClient

type InternalAuthorizeServiceServer added in v0.5.0 

type InternalAuthorizeServiceServer interface {
	Authorize(context.Context, *AuthorizeRequest) (*AuthorizeResponse, error)
	GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)
}

InternalAuthorizeServiceServer is the server API for InternalAuthorizeService service. All implementations should embed UnimplementedInternalAuthorizeServiceServer for forward compatibility

type InternalEventEmitterServiceClient added in v0.5.0 

type InternalEventEmitterServiceClient interface {
	EmitEvent(ctx context.Context, in *EmitEventRequest, opts ...grpc.CallOption) (*EmitEventResponse, error)
}

InternalEventEmitterServiceClient is the client API for InternalEventEmitterService 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 NewInternalEventEmitterServiceClient added in v0.5.0 

func NewInternalEventEmitterServiceClient(cc grpc.ClientConnInterface) InternalEventEmitterServiceClient

type InternalEventEmitterServiceServer added in v0.5.0 

type InternalEventEmitterServiceServer interface {
	EmitEvent(context.Context, *EmitEventRequest) (*EmitEventResponse, error)
}

InternalEventEmitterServiceServer is the server API for InternalEventEmitterService service. All implementations should embed UnimplementedInternalEventEmitterServiceServer for forward compatibility

type InternalEventServiceClient added in v0.5.0 

type InternalEventServiceClient interface {
	CreateStreamGroup(ctx context.Context, in *CreateStreamGroupRequest, opts ...grpc.CallOption) (*CreateStreamGroupResponse, error)
	GetStreamGroup(ctx context.Context, in *GetStreamGroupRequest, opts ...grpc.CallOption) (*GetStreamGroupResponse, error)
	DeleteStreamGroup(ctx context.Context, in *DeleteStreamGroupRequest, opts ...grpc.CallOption) (*DeleteStreamGroupResponse, error)
	GetSharedRevision(ctx context.Context, in *GetSharedRevisionRequest, opts ...grpc.CallOption) (*GetSharedRevisionResponse, error)
}

InternalEventServiceClient is the client API for InternalEventService 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 NewInternalEventServiceClient added in v0.5.0 

func NewInternalEventServiceClient(cc grpc.ClientConnInterface) InternalEventServiceClient

type InternalEventServiceServer added in v0.5.0 

type InternalEventServiceServer interface {
	CreateStreamGroup(context.Context, *CreateStreamGroupRequest) (*CreateStreamGroupResponse, error)
	GetStreamGroup(context.Context, *GetStreamGroupRequest) (*GetStreamGroupResponse, error)
	DeleteStreamGroup(context.Context, *DeleteStreamGroupRequest) (*DeleteStreamGroupResponse, error)
	GetSharedRevision(context.Context, *GetSharedRevisionRequest) (*GetSharedRevisionResponse, error)
}

InternalEventServiceServer is the server API for InternalEventService service. All implementations should embed UnimplementedInternalEventServiceServer for forward compatibility

type InternalProxyNotifierServiceClient added in v1.0.0 

type InternalProxyNotifierServiceClient interface {
	GetOrCreateObjectByPath(ctx context.Context, in *GetOrCreateObjectByPathRequest, opts ...grpc.CallOption) (*GetOrCreateObjectByPathResponse, error)
	FinalizeObject(ctx context.Context, in *FinalizeObjectRequest, opts ...grpc.CallOption) (*FinalizeObjectResponse, error)
	GetOrCreateEncryptionKey(ctx context.Context, in *GetOrCreateEncryptionKeyRequest, opts ...grpc.CallOption) (*GetOrCreateEncryptionKeyResponse, error)
	GetObjectLocation(ctx context.Context, in *GetObjectLocationRequest, opts ...grpc.CallOption) (*GetObjectLocationResponse, error)
	GetCollectionByBucket(ctx context.Context, in *GetCollectionByBucketRequest, opts ...grpc.CallOption) (*GetCollectionByBucketResponse, error)
}

InternalProxyNotifierServiceClient is the client API for InternalProxyNotifierService 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 NewInternalProxyNotifierServiceClient added in v1.0.0 

func NewInternalProxyNotifierServiceClient(cc grpc.ClientConnInterface) InternalProxyNotifierServiceClient

type InternalProxyNotifierServiceServer added in v1.0.0 

type InternalProxyNotifierServiceServer interface {
	GetOrCreateObjectByPath(context.Context, *GetOrCreateObjectByPathRequest) (*GetOrCreateObjectByPathResponse, error)
	FinalizeObject(context.Context, *FinalizeObjectRequest) (*FinalizeObjectResponse, error)
	GetOrCreateEncryptionKey(context.Context, *GetOrCreateEncryptionKeyRequest) (*GetOrCreateEncryptionKeyResponse, error)
	GetObjectLocation(context.Context, *GetObjectLocationRequest) (*GetObjectLocationResponse, error)
	GetCollectionByBucket(context.Context, *GetCollectionByBucketRequest) (*GetCollectionByBucketResponse, error)
}

InternalProxyNotifierServiceServer is the server API for InternalProxyNotifierService service. All implementations should embed UnimplementedInternalProxyNotifierServiceServer for forward compatibility

type InternalProxyServiceClient 

type InternalProxyServiceClient interface {
	InitMultipartUpload(ctx context.Context, in *InitMultipartUploadRequest, opts ...grpc.CallOption) (*InitMultipartUploadResponse, error)
	FinishMultipartUpload(ctx context.Context, in *FinishMultipartUploadRequest, opts ...grpc.CallOption) (*FinishMultipartUploadResponse, error)
	DeleteObject(ctx context.Context, in *DeleteObjectRequest, opts ...grpc.CallOption) (*DeleteObjectResponse, error)
}

InternalProxyServiceClient is the client API for InternalProxyService 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 NewInternalProxyServiceClient 

func NewInternalProxyServiceClient(cc grpc.ClientConnInterface) InternalProxyServiceClient

type InternalProxyServiceServer 

type InternalProxyServiceServer interface {
	InitMultipartUpload(context.Context, *InitMultipartUploadRequest) (*InitMultipartUploadResponse, error)
	FinishMultipartUpload(context.Context, *FinishMultipartUploadRequest) (*FinishMultipartUploadResponse, error)
	DeleteObject(context.Context, *DeleteObjectRequest) (*DeleteObjectResponse, error)
}

InternalProxyServiceServer is the server API for InternalProxyService service. All implementations should embed UnimplementedInternalProxyServiceServer for forward compatibility

type Location 

type Location struct {
	Type   LocationType `protobuf:"varint,1,opt,name=type,proto3,enum=aruna.api.internal.v1.LocationType" json:"type,omitempty"`
	Bucket string       `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"` // This is the bucket name for S3. This is the folder name
	// for local file.
	Path          string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"` // This is the key name for S3. This is the file name for local file.
	EndpointId    string `protobuf:"bytes,4,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	IsCompressed  bool   `protobuf:"varint,5,opt,name=is_compressed,json=isCompressed,proto3" json:"is_compressed,omitempty"`
	IsEncrypted   bool   `protobuf:"varint,6,opt,name=is_encrypted,json=isEncrypted,proto3" json:"is_encrypted,omitempty"`
	EncryptionKey string `protobuf:"bytes,7,opt,name=encryption_key,json=encryptionKey,proto3" json:"encryption_key,omitempty"`
	// contains filtered or unexported fields
}

Locations is the path to the requested data.

func (*Location) Descriptor deprecated 

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

Deprecated: Use Location.ProtoReflect.Descriptor instead.

func (*Location) GetBucket 

func (x *Location) GetBucket() string

func (*Location) GetEncryptionKey added in v1.0.0 

func (x *Location) GetEncryptionKey() string

func (*Location) GetEndpointId added in v1.0.0 

func (x *Location) GetEndpointId() string

func (*Location) GetIsCompressed added in v1.0.0 

func (x *Location) GetIsCompressed() bool

func (*Location) GetIsEncrypted added in v1.0.0 

func (x *Location) GetIsEncrypted() bool

func (*Location) GetPath 

func (x *Location) GetPath() string

func (*Location) GetType 

func (x *Location) GetType() LocationType

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) ProtoReflect 

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

func (*Location) Reset 

func (x *Location) Reset()

func (*Location) String 

func (x *Location) String() string

type LocationType 

type LocationType int32

Enum to support multiple target Locations. 

const (
	LocationType_LOCATION_TYPE_UNSPECIFIED LocationType = 0
	LocationType_LOCATION_TYPE_S3          LocationType = 1
	LocationType_LOCATION_TYPE_FILE        LocationType = 2
)

func (LocationType) Descriptor 

func (LocationType) Descriptor() protoreflect.EnumDescriptor

func (LocationType) Enum 

func (x LocationType) Enum() *LocationType

func (LocationType) EnumDescriptor deprecated 

func (LocationType) EnumDescriptor() ([]byte, []int)

Deprecated: Use LocationType.Descriptor instead.

func (LocationType) Number 

func (x LocationType) Number() protoreflect.EnumNumber

func (LocationType) String 

func (x LocationType) String() string

func (LocationType) Type 

func (LocationType) Type() protoreflect.EnumType

type ObjectGroupResource added in v1.0.0 

type ObjectGroupResource struct {
	ProjectId           string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	CollectionId        string `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	SharedObjectGroupId string `protobuf:"bytes,3,opt,name=shared_object_group_id,json=sharedObjectGroupId,proto3" json:"shared_object_group_id,omitempty"`
	ObjectGroupId       string `protobuf:"bytes,4,opt,name=object_group_id,json=objectGroupId,proto3" json:"object_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectGroupResource) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use ObjectGroupResource.ProtoReflect.Descriptor instead.

func (*ObjectGroupResource) GetCollectionId added in v1.0.0 

func (x *ObjectGroupResource) GetCollectionId() string

func (*ObjectGroupResource) GetObjectGroupId added in v1.0.0 

func (x *ObjectGroupResource) GetObjectGroupId() string

func (*ObjectGroupResource) GetProjectId added in v1.0.0 

func (x *ObjectGroupResource) GetProjectId() string

func (*ObjectGroupResource) GetSharedObjectGroupId added in v1.0.0 

func (x *ObjectGroupResource) GetSharedObjectGroupId() string

func (*ObjectGroupResource) ProtoMessage added in v1.0.0 

func (*ObjectGroupResource) ProtoMessage()

func (*ObjectGroupResource) ProtoReflect added in v1.0.0 

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

func (*ObjectGroupResource) Reset added in v1.0.0 

func (x *ObjectGroupResource) Reset()

func (*ObjectGroupResource) String added in v1.0.0 

func (x *ObjectGroupResource) String() string

type ObjectResource added in v1.0.0 

type ObjectResource struct {
	ProjectId      string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	CollectionId   string `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	SharedObjectId string `protobuf:"bytes,3,opt,name=shared_object_id,json=sharedObjectId,proto3" json:"shared_object_id,omitempty"`
	ObjectId       string `protobuf:"bytes,4,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectResource) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use ObjectResource.ProtoReflect.Descriptor instead.

func (*ObjectResource) GetCollectionId added in v1.0.0 

func (x *ObjectResource) GetCollectionId() string

func (*ObjectResource) GetObjectId added in v1.0.0 

func (x *ObjectResource) GetObjectId() string

func (*ObjectResource) GetProjectId added in v1.0.0 

func (x *ObjectResource) GetProjectId() string

func (*ObjectResource) GetSharedObjectId added in v1.0.0 

func (x *ObjectResource) GetSharedObjectId() string

func (*ObjectResource) ProtoMessage added in v1.0.0 

func (*ObjectResource) ProtoMessage()

func (*ObjectResource) ProtoReflect added in v1.0.0 

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

func (*ObjectResource) Reset added in v1.0.0 

func (x *ObjectResource) Reset()

func (*ObjectResource) String added in v1.0.0 

func (x *ObjectResource) String() string

type PartETag 

type PartETag struct {
	PartNumber int64  `protobuf:"varint,1,opt,name=part_number,json=partNumber,proto3" json:"part_number,omitempty"`
	Etag       string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

Etag / Part combination to finish a presigned multipart upload.

func (*PartETag) Descriptor deprecated 

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

Deprecated: Use PartETag.ProtoReflect.Descriptor instead.

func (*PartETag) GetEtag 

func (x *PartETag) GetEtag() string

func (*PartETag) GetPartNumber 

func (x *PartETag) GetPartNumber() int64

func (*PartETag) ProtoMessage 

func (*PartETag) ProtoMessage()

func (*PartETag) ProtoReflect 

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

func (*PartETag) Reset 

func (x *PartETag) Reset()

func (*PartETag) String 

func (x *PartETag) String() string

type ProjectResource added in v1.0.0 

type ProjectResource struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectResource) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use ProjectResource.ProtoReflect.Descriptor instead.

func (*ProjectResource) GetProjectId added in v1.0.0 

func (x *ProjectResource) GetProjectId() string

func (*ProjectResource) ProtoMessage added in v1.0.0 

func (*ProjectResource) ProtoMessage()

func (*ProjectResource) ProtoReflect added in v1.0.0 

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

func (*ProjectResource) Reset added in v1.0.0 

func (x *ProjectResource) Reset()

func (*ProjectResource) String added in v1.0.0 

func (x *ProjectResource) String() string

type StreamGroup added in v0.5.0 

type StreamGroup struct {

	// Stream group ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Event this streamgroup is listening for
	EventType v11.EventType `` /* 139-byte string literal not displayed */
	// Type of the resource (Collection, Object etc.)
	ResourceType v1.ResourceType `` /* 144-byte string literal not displayed */
	// Resource ID
	ResourceId string `protobuf:"bytes,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// Should all "sub" resources be included
	NotifyOnSubResource bool `protobuf:"varint,5,opt,name=notify_on_sub_resource,json=notifyOnSubResource,proto3" json:"notify_on_sub_resource,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamGroup) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use StreamGroup.ProtoReflect.Descriptor instead.

func (*StreamGroup) GetEventType added in v0.5.0 

func (x *StreamGroup) GetEventType() v11.EventType

func (*StreamGroup) GetId added in v0.5.0 

func (x *StreamGroup) GetId() string

func (*StreamGroup) GetNotifyOnSubResource added in v0.5.0 

func (x *StreamGroup) GetNotifyOnSubResource() bool

func (*StreamGroup) GetResourceId added in v0.5.0 

func (x *StreamGroup) GetResourceId() string

func (*StreamGroup) GetResourceType added in v0.5.0 

func (x *StreamGroup) GetResourceType() v1.ResourceType

func (*StreamGroup) ProtoMessage added in v0.5.0 

func (*StreamGroup) ProtoMessage()

func (*StreamGroup) ProtoReflect added in v0.5.0 

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

func (*StreamGroup) Reset added in v0.5.0 

func (x *StreamGroup) Reset()

func (*StreamGroup) String added in v0.5.0 

func (x *StreamGroup) String() string

type UnimplementedInternalAuthorizeServiceServer added in v0.5.0 

type UnimplementedInternalAuthorizeServiceServer struct {
}

UnimplementedInternalAuthorizeServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedInternalAuthorizeServiceServer) Authorize added in v0.5.0 

func (UnimplementedInternalAuthorizeServiceServer) Authorize(context.Context, *AuthorizeRequest) (*AuthorizeResponse, error)

func (UnimplementedInternalAuthorizeServiceServer) GetSecret added in v1.0.0 

func (UnimplementedInternalAuthorizeServiceServer) GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)

type UnimplementedInternalEventEmitterServiceServer added in v0.5.0 

type UnimplementedInternalEventEmitterServiceServer struct {
}

UnimplementedInternalEventEmitterServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedInternalEventEmitterServiceServer) EmitEvent added in v0.5.0 

func (UnimplementedInternalEventEmitterServiceServer) EmitEvent(context.Context, *EmitEventRequest) (*EmitEventResponse, error)

type UnimplementedInternalEventServiceServer added in v0.5.0 

type UnimplementedInternalEventServiceServer struct {
}

UnimplementedInternalEventServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedInternalEventServiceServer) CreateStreamGroup added in v0.5.0 

func (UnimplementedInternalEventServiceServer) CreateStreamGroup(context.Context, *CreateStreamGroupRequest) (*CreateStreamGroupResponse, error)

func (UnimplementedInternalEventServiceServer) DeleteStreamGroup added in v0.5.0 

func (UnimplementedInternalEventServiceServer) DeleteStreamGroup(context.Context, *DeleteStreamGroupRequest) (*DeleteStreamGroupResponse, error)

func (UnimplementedInternalEventServiceServer) GetSharedRevision added in v0.5.0 

func (UnimplementedInternalEventServiceServer) GetSharedRevision(context.Context, *GetSharedRevisionRequest) (*GetSharedRevisionResponse, error)

func (UnimplementedInternalEventServiceServer) GetStreamGroup added in v0.5.0 

func (UnimplementedInternalEventServiceServer) GetStreamGroup(context.Context, *GetStreamGroupRequest) (*GetStreamGroupResponse, error)

type UnimplementedInternalProxyNotifierServiceServer added in v1.0.0 

type UnimplementedInternalProxyNotifierServiceServer struct {
}

UnimplementedInternalProxyNotifierServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedInternalProxyNotifierServiceServer) FinalizeObject added in v1.0.0 

func (UnimplementedInternalProxyNotifierServiceServer) FinalizeObject(context.Context, *FinalizeObjectRequest) (*FinalizeObjectResponse, error)

func (UnimplementedInternalProxyNotifierServiceServer) GetCollectionByBucket added in v1.0.0 

func (UnimplementedInternalProxyNotifierServiceServer) GetCollectionByBucket(context.Context, *GetCollectionByBucketRequest) (*GetCollectionByBucketResponse, error)

func (UnimplementedInternalProxyNotifierServiceServer) GetObjectLocation added in v1.0.0 

func (UnimplementedInternalProxyNotifierServiceServer) GetObjectLocation(context.Context, *GetObjectLocationRequest) (*GetObjectLocationResponse, error)

func (UnimplementedInternalProxyNotifierServiceServer) GetOrCreateEncryptionKey added in v1.0.0 

func (UnimplementedInternalProxyNotifierServiceServer) GetOrCreateEncryptionKey(context.Context, *GetOrCreateEncryptionKeyRequest) (*GetOrCreateEncryptionKeyResponse, error)

func (UnimplementedInternalProxyNotifierServiceServer) GetOrCreateObjectByPath added in v1.0.0 

func (UnimplementedInternalProxyNotifierServiceServer) GetOrCreateObjectByPath(context.Context, *GetOrCreateObjectByPathRequest) (*GetOrCreateObjectByPathResponse, error)

type UnimplementedInternalProxyServiceServer 

type UnimplementedInternalProxyServiceServer struct {
}

UnimplementedInternalProxyServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedInternalProxyServiceServer) DeleteObject added in v1.0.0 

func (UnimplementedInternalProxyServiceServer) DeleteObject(context.Context, *DeleteObjectRequest) (*DeleteObjectResponse, error)

func (UnimplementedInternalProxyServiceServer) FinishMultipartUpload added in v1.0.0 

func (UnimplementedInternalProxyServiceServer) FinishMultipartUpload(context.Context, *FinishMultipartUploadRequest) (*FinishMultipartUploadResponse, error)

func (UnimplementedInternalProxyServiceServer) InitMultipartUpload added in v1.0.0 

func (UnimplementedInternalProxyServiceServer) InitMultipartUpload(context.Context, *InitMultipartUploadRequest) (*InitMultipartUploadResponse, error)

type UnsafeInternalAuthorizeServiceServer added in v0.5.0 

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

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

type UnsafeInternalEventEmitterServiceServer added in v0.5.0 

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

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

type UnsafeInternalEventServiceServer added in v0.5.0 

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

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

type UnsafeInternalProxyNotifierServiceServer added in v1.0.0 

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

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

type UnsafeInternalProxyServiceServer 

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

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

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.