object

package
v5.0.1 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2026 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

View Source 
const (
	StorageKeyFolder           = "folder"
	StorageKeyFolderCreate     = "create"
	StorageKeyNormalize        = "normalize"
	StorageKeyFlatShardFolders = "foldersShardingPattern"

	StorageKeyCustomEndpoint   = "customEndpoint"
	StorageKeyCustomRegion     = "customRegion"
	StorageKeyMinioServer      = "minioServer"
	StorageKeyBucketsTags      = "bucketsTags"
	StorageKeyObjectsTags      = "objectsTags"
	StorageKeyNativeEtags      = "nativeEtags"
	StorageKeyBucketsRegexp    = "bucketsRegexp"
	StorageKeyReadonly         = "readOnly"
	StorageKeyJsonCredentials  = "jsonCredentials"
	StorageKeyStorageClass     = "storageClass"
	StorageKeySignatureVersion = "signatureVersion"

	StorageKeyCellsInternal    = "cellsInternal"
	StorageKeyInitFromBucket   = "initFromBucket"
	StorageKeyInitFromSnapshot = "initFromSnapshot"
	StorageKeyHashingVersion   = "hashingVersion"

	AmazonS3Endpoint      = "s3.amazonaws.com"
	CurrentHashingVersion = "v4"
)

Variables ¶

View Source 
var (
	StorageType_name = map[int32]string{
		0: "LOCAL",
		1: "S3",
		2: "SMB",
		4: "CELLS",
		5: "AZURE",
		6: "GCS",
		7: "B2",
		8: "MANTA",
		9: "SIA",
	}
	StorageType_value = map[string]int32{
		"LOCAL": 0,
		"S3":    1,
		"SMB":   2,
		"CELLS": 4,
		"AZURE": 5,
		"GCS":   6,
		"B2":    7,
		"MANTA": 8,
		"SIA":   9,
	}
)

Enum value maps for StorageType.

View Source 
var (
	EncryptionMode_name = map[int32]string{
		0: "CLEAR",
		1: "MASTER",
		2: "USER",
		3: "USER_PWD",
	}
	EncryptionMode_value = map[string]int32{
		"CLEAR":    0,
		"MASTER":   1,
		"USER":     2,
		"USER_PWD": 3,
	}
)

Enum value maps for EncryptionMode.

View Source 
var (
	StorageTypeFilter_name = map[int32]string{
		0: "ANY",
		1: "LOCALFS",
		2: "REMOTE",
	}
	StorageTypeFilter_value = map[string]int32{
		"ANY":     0,
		"LOCALFS": 1,
		"REMOTE":  2,
	}
)

Enum value maps for StorageTypeFilter.

View Source 
var (
	DataSourceEvent_DSEventType_name = map[int32]string{
		0: "CREATE",
		1: "UPDATE",
		2: "DELETE",
		3: "ENABLED",
		4: "DISABLED",
	}
	DataSourceEvent_DSEventType_value = map[string]int32{
		"CREATE":   0,
		"UPDATE":   1,
		"DELETE":   2,
		"ENABLED":  3,
		"DISABLED": 4,
	}
)

Enum value maps for DataSourceEvent_DSEventType.

View Source 
var DataSourceEndpoint_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "object.DataSourceEndpoint",
	HandlerType: (*DataSourceEndpointServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDataSourceConfig",
			Handler:    _DataSourceEndpoint_GetDataSourceConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cells-object.proto",
}

DataSourceEndpoint_ServiceDesc is the grpc.ServiceDesc for DataSourceEndpoint 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 File_cells_object_proto protoreflect.FileDescriptor
View Source 
var ObjectsEndpoint_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "object.ObjectsEndpoint",
	HandlerType: (*ObjectsEndpointServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMinioConfig",
			Handler:    _ObjectsEndpoint_GetMinioConfig_Handler,
		},
		{
			MethodName: "StorageStats",
			Handler:    _ObjectsEndpoint_StorageStats_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cells-object.proto",
}

ObjectsEndpoint_ServiceDesc is the grpc.ServiceDesc for ObjectsEndpoint 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 ResourceCleanerEndpoint_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "object.ResourceCleanerEndpoint",
	HandlerType: (*ResourceCleanerEndpointServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CleanResourcesBeforeDelete",
			Handler:    _ResourceCleanerEndpoint_CleanResourcesBeforeDelete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cells-object.proto",
}

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

Functions ¶

func RegisterDataSourceEndpointServer ¶ 

func RegisterDataSourceEndpointServer(s grpc.ServiceRegistrar, srv DataSourceEndpointServer)

func RegisterObjectsEndpointServer ¶ 

func RegisterObjectsEndpointServer(s grpc.ServiceRegistrar, srv ObjectsEndpointServer)

func RegisterResourceCleanerEndpointServer ¶ 

func RegisterResourceCleanerEndpointServer(s grpc.ServiceRegistrar, srv ResourceCleanerEndpointServer)

Types ¶

type CleanResourcesRequest ¶ 

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

func (*CleanResourcesRequest) Descriptor deprecated 

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

Deprecated: Use CleanResourcesRequest.ProtoReflect.Descriptor instead.

func (*CleanResourcesRequest) ProtoMessage ¶ 

func (*CleanResourcesRequest) ProtoMessage()

func (*CleanResourcesRequest) ProtoReflect ¶ 

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

func (*CleanResourcesRequest) Reset ¶ 

func (x *CleanResourcesRequest) Reset()

func (*CleanResourcesRequest) String ¶ 

func (x *CleanResourcesRequest) String() string

type CleanResourcesResponse ¶ 

type CleanResourcesResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*CleanResourcesResponse) Descriptor deprecated 

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

Deprecated: Use CleanResourcesResponse.ProtoReflect.Descriptor instead.

func (*CleanResourcesResponse) GetMessage ¶ 

func (x *CleanResourcesResponse) GetMessage() string

func (*CleanResourcesResponse) GetSuccess ¶ 

func (x *CleanResourcesResponse) GetSuccess() bool

func (*CleanResourcesResponse) ProtoMessage ¶ 

func (*CleanResourcesResponse) ProtoMessage()

func (*CleanResourcesResponse) ProtoReflect ¶ 

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

func (*CleanResourcesResponse) Reset ¶ 

func (x *CleanResourcesResponse) Reset()

func (*CleanResourcesResponse) String ¶ 

func (x *CleanResourcesResponse) String() string

type DataSource ¶ 

type DataSource struct {

	// Name of the data source (max length 34)
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// Whether this data source is disabled or running
	Disabled bool `protobuf:"varint,2,opt,name=Disabled,proto3" json:"Disabled,omitempty"`
	// Type of underlying storage (LOCAL, S3, AZURE, GCS)
	StorageType StorageType `protobuf:"varint,3,opt,name=StorageType,proto3,enum=object.StorageType" json:"StorageType,omitempty"`
	// List of key values describing storage configuration
	StorageConfiguration map[string]string `` /* 181-byte string literal not displayed */
	// Corresponding objects service name (underlying s3 service)
	ObjectsServiceName string `protobuf:"bytes,18,opt,name=ObjectsServiceName,proto3" json:"ObjectsServiceName,omitempty"`
	// Corresponding objects service host
	ObjectsHost string `protobuf:"bytes,12,opt,name=ObjectsHost,proto3" json:"ObjectsHost,omitempty"`
	// Corresponding objects service port
	ObjectsPort int32 `protobuf:"varint,5,opt,name=ObjectsPort,proto3" json:"ObjectsPort,omitempty"`
	// Corresponding objects service connection type
	ObjectsSecure bool `protobuf:"varint,13,opt,name=ObjectsSecure,proto3" json:"ObjectsSecure,omitempty"`
	// Corresponding objects service bucket
	ObjectsBucket string `protobuf:"bytes,14,opt,name=ObjectsBucket,proto3" json:"ObjectsBucket,omitempty"`
	// Corresponding objects service base folder inside the bucket
	ObjectsBaseFolder string `protobuf:"bytes,15,opt,name=ObjectsBaseFolder,proto3" json:"ObjectsBaseFolder,omitempty"`
	// Corresponding objects service api key
	ApiKey string `protobuf:"bytes,16,opt,name=ApiKey,proto3" json:"ApiKey,omitempty"`
	// Corresponding objects service api secret
	ApiSecret string `protobuf:"bytes,17,opt,name=ApiSecret,proto3" json:"ApiSecret,omitempty"`
	// Peer address of the data source
	PeerAddress string `protobuf:"bytes,19,opt,name=PeerAddress,proto3" json:"PeerAddress,omitempty"`
	// Not implemented, whether to watch for underlying changes on the FS
	Watch bool `protobuf:"varint,6,opt,name=Watch,proto3" json:"Watch,omitempty"`
	// Store data in flat format (object-storage like)
	FlatStorage bool `protobuf:"varint,20,opt,name=FlatStorage,proto3" json:"FlatStorage,omitempty"`
	// Do not trigger resync at start
	SkipSyncOnRestart bool `protobuf:"varint,21,opt,name=SkipSyncOnRestart,proto3" json:"SkipSyncOnRestart,omitempty"`
	// Type of encryption applied before sending data to storage
	EncryptionMode EncryptionMode `protobuf:"varint,7,opt,name=EncryptionMode,proto3,enum=object.EncryptionMode" json:"EncryptionMode,omitempty"`
	// Encryption key used for encrypting data
	EncryptionKey string `protobuf:"bytes,8,opt,name=EncryptionKey,proto3" json:"EncryptionKey,omitempty"`
	// Versioning policy describes how files are kept in the versioning queue
	VersioningPolicyName string `protobuf:"bytes,9,opt,name=VersioningPolicyName,proto3" json:"VersioningPolicyName,omitempty"`
	// Data Source creation date
	CreationDate int32 `protobuf:"varint,10,opt,name=CreationDate,proto3" json:"CreationDate,omitempty"`
	// Data Source last synchronization date
	LastSynchronizationDate int32 `protobuf:"varint,11,opt,name=LastSynchronizationDate,proto3" json:"LastSynchronizationDate,omitempty"`
	// contains filtered or unexported fields
}

DataSource Object description

func (*DataSource) BuildUrl ¶ 

func (d *DataSource) BuildUrl() string

BuildUrl constructs the url used for clients.

func (*DataSource) ClientConfig ¶ 

func (d *DataSource) ClientConfig(ctx context.Context, p SecretProvider) kv.Values

func (*DataSource) ConfigurationByKey ¶ 

func (d *DataSource) ConfigurationByKey(k string) (string, bool)

ConfigurationByKey wraps a check on d.StorageConfiguration to make sure it is not nil

func (*DataSource) Descriptor deprecated 

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

Deprecated: Use DataSource.ProtoReflect.Descriptor instead.

func (*DataSource) FlatShardedPath ¶ 

func (d *DataSource) FlatShardedPath(nodeId string) string

func (*DataSource) GetApiKey ¶ 

func (x *DataSource) GetApiKey() string

func (*DataSource) GetApiSecret ¶ 

func (x *DataSource) GetApiSecret() string

func (*DataSource) GetCreationDate ¶ 

func (x *DataSource) GetCreationDate() int32

func (*DataSource) GetDisabled ¶ 

func (x *DataSource) GetDisabled() bool

func (*DataSource) GetEncryptionKey ¶ 

func (x *DataSource) GetEncryptionKey() string

func (*DataSource) GetEncryptionMode ¶ 

func (x *DataSource) GetEncryptionMode() EncryptionMode

func (*DataSource) GetFlatStorage ¶ 

func (x *DataSource) GetFlatStorage() bool

func (*DataSource) GetLastSynchronizationDate ¶ 

func (x *DataSource) GetLastSynchronizationDate() int32

func (*DataSource) GetName ¶ 

func (x *DataSource) GetName() string

func (*DataSource) GetObjectsBaseFolder ¶ 

func (x *DataSource) GetObjectsBaseFolder() string

func (*DataSource) GetObjectsBucket ¶ 

func (x *DataSource) GetObjectsBucket() string

func (*DataSource) GetObjectsHost ¶ 

func (x *DataSource) GetObjectsHost() string

func (*DataSource) GetObjectsPort ¶ 

func (x *DataSource) GetObjectsPort() int32

func (*DataSource) GetObjectsSecure ¶ 

func (x *DataSource) GetObjectsSecure() bool

func (*DataSource) GetObjectsServiceName ¶ 

func (x *DataSource) GetObjectsServiceName() string

func (*DataSource) GetPeerAddress ¶ 

func (x *DataSource) GetPeerAddress() string

func (*DataSource) GetSkipSyncOnRestart ¶ 

func (x *DataSource) GetSkipSyncOnRestart() bool

func (*DataSource) GetStorageConfiguration ¶ 

func (x *DataSource) GetStorageConfiguration() map[string]string

func (*DataSource) GetStorageType ¶ 

func (x *DataSource) GetStorageType() StorageType

func (*DataSource) GetVersioningPolicyName ¶ 

func (x *DataSource) GetVersioningPolicyName() string

func (*DataSource) GetWatch ¶ 

func (x *DataSource) GetWatch() bool

func (*DataSource) IsInternal ¶ 

func (d *DataSource) IsInternal() bool

IsInternal is a shorthand to check StorageConfiguration["cellsInternal"] key

func (*DataSource) MarshalLogObject ¶ 

func (d *DataSource) MarshalLogObject(encoder zapcore.ObjectEncoder) error

MarshalLogObject implements custom marshalling for datasource, to avoid logging ApiKey

func (*DataSource) ProtoMessage ¶ 

func (*DataSource) ProtoMessage()

func (*DataSource) ProtoReflect ¶ 

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

func (*DataSource) Reset ¶ 

func (x *DataSource) Reset()

func (*DataSource) ServerIsMinio ¶ 

func (d *DataSource) ServerIsMinio() bool

ServerIsMinio checks if server is local, of if remote definition has the minioServer key

func (*DataSource) String ¶ 

func (x *DataSource) String() string

type DataSourceEndpointClient ¶ 

type DataSourceEndpointClient interface {
	GetDataSourceConfig(ctx context.Context, in *GetDataSourceConfigRequest, opts ...grpc.CallOption) (*GetDataSourceConfigResponse, error)
}

DataSourceEndpointClient is the client API for DataSourceEndpoint 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 NewDataSourceEndpointClient ¶ 

func NewDataSourceEndpointClient(cc grpc.ClientConnInterface) DataSourceEndpointClient

type DataSourceEndpointServer ¶ 

type DataSourceEndpointServer interface {
	GetDataSourceConfig(context.Context, *GetDataSourceConfigRequest) (*GetDataSourceConfigResponse, error)
	// contains filtered or unexported methods
}

DataSourceEndpointServer is the server API for DataSourceEndpoint service. All implementations must embed UnimplementedDataSourceEndpointServer for forward compatibility

type DataSourceEvent ¶ 

type DataSourceEvent struct {
	Type   DataSourceEvent_DSEventType `protobuf:"varint,1,opt,name=Type,proto3,enum=object.DataSourceEvent_DSEventType" json:"Type,omitempty"`
	Name   string                      `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Config *DataSource                 `protobuf:"bytes,3,opt,name=Config,proto3" json:"Config,omitempty"`
	// contains filtered or unexported fields
}

Used to dispatch some specific events across services

func (*DataSourceEvent) Descriptor deprecated 

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

Deprecated: Use DataSourceEvent.ProtoReflect.Descriptor instead.

func (*DataSourceEvent) GetConfig ¶ 

func (x *DataSourceEvent) GetConfig() *DataSource

func (*DataSourceEvent) GetName ¶ 

func (x *DataSourceEvent) GetName() string

func (*DataSourceEvent) GetType ¶ 

func (x *DataSourceEvent) GetType() DataSourceEvent_DSEventType

func (*DataSourceEvent) ProtoMessage ¶ 

func (*DataSourceEvent) ProtoMessage()

func (*DataSourceEvent) ProtoReflect ¶ 

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

func (*DataSourceEvent) Reset ¶ 

func (x *DataSourceEvent) Reset()

func (*DataSourceEvent) String ¶ 

func (x *DataSourceEvent) String() string

type DataSourceEvent_DSEventType ¶ 

type DataSourceEvent_DSEventType int32
const (
	DataSourceEvent_CREATE   DataSourceEvent_DSEventType = 0
	DataSourceEvent_UPDATE   DataSourceEvent_DSEventType = 1
	DataSourceEvent_DELETE   DataSourceEvent_DSEventType = 2
	DataSourceEvent_ENABLED  DataSourceEvent_DSEventType = 3
	DataSourceEvent_DISABLED DataSourceEvent_DSEventType = 4
)

func (DataSourceEvent_DSEventType) Descriptor ¶ 

func (DataSourceEvent_DSEventType) Descriptor() protoreflect.EnumDescriptor

func (DataSourceEvent_DSEventType) Enum ¶ 

func (x DataSourceEvent_DSEventType) Enum() *DataSourceEvent_DSEventType

func (DataSourceEvent_DSEventType) EnumDescriptor deprecated 

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

Deprecated: Use DataSourceEvent_DSEventType.Descriptor instead.

func (DataSourceEvent_DSEventType) Number ¶ 

func (x DataSourceEvent_DSEventType) Number() protoreflect.EnumNumber

func (DataSourceEvent_DSEventType) String ¶ 

func (x DataSourceEvent_DSEventType) String() string

func (DataSourceEvent_DSEventType) Type ¶ 

func (DataSourceEvent_DSEventType) Type() protoreflect.EnumType

type DataSourceSingleQuery ¶ 

type DataSourceSingleQuery struct {

	// Lookup DataSource by Name
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// Check if DataSource is Disabled or not
	IsDisabled bool `protobuf:"varint,2,opt,name=IsDisabled,proto3" json:"IsDisabled,omitempty"`
	// Restrict to a specific Storage Type
	StorageType StorageTypeFilter `protobuf:"varint,3,opt,name=StorageType,proto3,enum=object.StorageTypeFilter" json:"StorageType,omitempty"`
	// Restrict to a specific PeerAddress
	PeerAddress string `protobuf:"bytes,4,opt,name=PeerAddress,proto3" json:"PeerAddress,omitempty"`
	// Flat datasources (appeared at version 3) store the files in an "object storage" way, instead of keeping the folders structure
	FlatStorage bool `protobuf:"varint,5,opt,name=FlatStorage,proto3" json:"FlatStorage,omitempty"`
	// Check if this flag is set
	SkipSyncOnRestart bool `protobuf:"varint,6,opt,name=SkipSyncOnRestart,proto3" json:"SkipSyncOnRestart,omitempty"`
	// Restrict to DataSource where versioning is enabled
	IsVersioned bool `protobuf:"varint,9,opt,name=IsVersioned,proto3" json:"IsVersioned,omitempty"`
	// Restrict to DataSource where encryption is enabled
	IsEncrypted bool `protobuf:"varint,17,opt,name=IsEncrypted,proto3" json:"IsEncrypted,omitempty"`
	// Along with IsEncrypted, restrict EncryptionMode
	EncryptionMode EncryptionMode `protobuf:"varint,7,opt,name=EncryptionMode,proto3,enum=object.EncryptionMode" json:"EncryptionMode,omitempty"`
	// Along with IsEncrypted, lookup by encryption key Id
	EncryptionKey string `protobuf:"bytes,8,opt,name=EncryptionKey,proto3" json:"EncryptionKey,omitempty"`
	// Along with IsVersioned, lookup by versioning policy name
	VersioningPolicyName string `protobuf:"bytes,10,opt,name=VersioningPolicyName,proto3" json:"VersioningPolicyName,omitempty"`
	// Lookup a key in the StorageConfiguration map. Frequently used keys: cellsInternal, folder, normalize (refer to the low-level configuration)
	StorageConfigurationName string `protobuf:"bytes,13,opt,name=StorageConfigurationName,proto3" json:"StorageConfigurationName,omitempty"`
	// Combined with StorageConfigurationName, value used for comparison
	StorageConfigurationValue string `protobuf:"bytes,14,opt,name=StorageConfigurationValue,proto3" json:"StorageConfigurationValue,omitempty"`
	// Restrict datasource attached to a specific Object service (see Services list)
	ObjectServiceName string `protobuf:"bytes,15,opt,name=ObjectServiceName,proto3" json:"ObjectServiceName,omitempty"`
	// Internal - Negate the query result
	Not bool `protobuf:"varint,16,opt,name=Not,proto3" json:"Not,omitempty"`
	// contains filtered or unexported fields
}

func (*DataSourceSingleQuery) Descriptor deprecated 

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

Deprecated: Use DataSourceSingleQuery.ProtoReflect.Descriptor instead.

func (*DataSourceSingleQuery) GetEncryptionKey ¶ 

func (x *DataSourceSingleQuery) GetEncryptionKey() string

func (*DataSourceSingleQuery) GetEncryptionMode ¶ 

func (x *DataSourceSingleQuery) GetEncryptionMode() EncryptionMode

func (*DataSourceSingleQuery) GetFlatStorage ¶ 

func (x *DataSourceSingleQuery) GetFlatStorage() bool

func (*DataSourceSingleQuery) GetIsDisabled ¶ 

func (x *DataSourceSingleQuery) GetIsDisabled() bool

func (*DataSourceSingleQuery) GetIsEncrypted ¶ 

func (x *DataSourceSingleQuery) GetIsEncrypted() bool

func (*DataSourceSingleQuery) GetIsVersioned ¶ 

func (x *DataSourceSingleQuery) GetIsVersioned() bool

func (*DataSourceSingleQuery) GetName ¶ 

func (x *DataSourceSingleQuery) GetName() string

func (*DataSourceSingleQuery) GetNot ¶ 

func (x *DataSourceSingleQuery) GetNot() bool

func (*DataSourceSingleQuery) GetObjectServiceName ¶ 

func (x *DataSourceSingleQuery) GetObjectServiceName() string

func (*DataSourceSingleQuery) GetPeerAddress ¶ 

func (x *DataSourceSingleQuery) GetPeerAddress() string

func (*DataSourceSingleQuery) GetSkipSyncOnRestart ¶ 

func (x *DataSourceSingleQuery) GetSkipSyncOnRestart() bool

func (*DataSourceSingleQuery) GetStorageConfigurationName ¶ 

func (x *DataSourceSingleQuery) GetStorageConfigurationName() string

func (*DataSourceSingleQuery) GetStorageConfigurationValue ¶ 

func (x *DataSourceSingleQuery) GetStorageConfigurationValue() string

func (*DataSourceSingleQuery) GetStorageType ¶ 

func (x *DataSourceSingleQuery) GetStorageType() StorageTypeFilter

func (*DataSourceSingleQuery) GetVersioningPolicyName ¶ 

func (x *DataSourceSingleQuery) GetVersioningPolicyName() string

func (*DataSourceSingleQuery) Matches ¶ 

func (m *DataSourceSingleQuery) Matches(ctx context.Context, object interface{}) bool

func (*DataSourceSingleQuery) ProtoMessage ¶ 

func (*DataSourceSingleQuery) ProtoMessage()

func (*DataSourceSingleQuery) ProtoReflect ¶ 

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

func (*DataSourceSingleQuery) Reset ¶ 

func (x *DataSourceSingleQuery) Reset()

func (*DataSourceSingleQuery) String ¶ 

func (x *DataSourceSingleQuery) String() string

type EncryptionMode ¶ 

type EncryptionMode int32

Type of Encryption 

const (
	EncryptionMode_CLEAR    EncryptionMode = 0
	EncryptionMode_MASTER   EncryptionMode = 1
	EncryptionMode_USER     EncryptionMode = 2
	EncryptionMode_USER_PWD EncryptionMode = 3
)

func (EncryptionMode) Descriptor ¶ 

func (EncryptionMode) Descriptor() protoreflect.EnumDescriptor

func (EncryptionMode) Enum ¶ 

func (x EncryptionMode) Enum() *EncryptionMode

func (EncryptionMode) EnumDescriptor deprecated 

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

Deprecated: Use EncryptionMode.Descriptor instead.

func (EncryptionMode) Number ¶ 

func (x EncryptionMode) Number() protoreflect.EnumNumber

func (EncryptionMode) String ¶ 

func (x EncryptionMode) String() string

func (EncryptionMode) Type ¶ 

func (EncryptionMode) Type() protoreflect.EnumType

type GetDataSourceConfigRequest ¶ 

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

func (*GetDataSourceConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetDataSourceConfigRequest.ProtoReflect.Descriptor instead.

func (*GetDataSourceConfigRequest) ProtoMessage ¶ 

func (*GetDataSourceConfigRequest) ProtoMessage()

func (*GetDataSourceConfigRequest) ProtoReflect ¶ 

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

func (*GetDataSourceConfigRequest) Reset ¶ 

func (x *GetDataSourceConfigRequest) Reset()

func (*GetDataSourceConfigRequest) String ¶ 

func (x *GetDataSourceConfigRequest) String() string

type GetDataSourceConfigResponse ¶ 

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

func (*GetDataSourceConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetDataSourceConfigResponse.ProtoReflect.Descriptor instead.

func (*GetDataSourceConfigResponse) GetDataSource ¶ 

func (x *GetDataSourceConfigResponse) GetDataSource() *DataSource

func (*GetDataSourceConfigResponse) ProtoMessage ¶ 

func (*GetDataSourceConfigResponse) ProtoMessage()

func (*GetDataSourceConfigResponse) ProtoReflect ¶ 

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

func (*GetDataSourceConfigResponse) Reset ¶ 

func (x *GetDataSourceConfigResponse) Reset()

func (*GetDataSourceConfigResponse) String ¶ 

func (x *GetDataSourceConfigResponse) String() string

type GetMinioConfigRequest ¶ 

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

func (*GetMinioConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetMinioConfigRequest.ProtoReflect.Descriptor instead.

func (*GetMinioConfigRequest) ProtoMessage ¶ 

func (*GetMinioConfigRequest) ProtoMessage()

func (*GetMinioConfigRequest) ProtoReflect ¶ 

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

func (*GetMinioConfigRequest) Reset ¶ 

func (x *GetMinioConfigRequest) Reset()

func (*GetMinioConfigRequest) String ¶ 

func (x *GetMinioConfigRequest) String() string

type GetMinioConfigResponse ¶ 

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

func (*GetMinioConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetMinioConfigResponse.ProtoReflect.Descriptor instead.

func (*GetMinioConfigResponse) GetMinioConfig ¶ 

func (x *GetMinioConfigResponse) GetMinioConfig() *MinioConfig

func (*GetMinioConfigResponse) ProtoMessage ¶ 

func (*GetMinioConfigResponse) ProtoMessage()

func (*GetMinioConfigResponse) ProtoReflect ¶ 

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

func (*GetMinioConfigResponse) Reset ¶ 

func (x *GetMinioConfigResponse) Reset()

func (*GetMinioConfigResponse) String ¶ 

func (x *GetMinioConfigResponse) String() string

type MinioConfig ¶ 

type MinioConfig struct {

	// Name of the object service
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// Underlying storage type (LOCAL, S3, AZURE, GCS)
	StorageType StorageType `protobuf:"varint,2,opt,name=StorageType,proto3,enum=object.StorageType" json:"StorageType,omitempty"`
	// Host where this minio is running
	RunningHost string `protobuf:"bytes,3,opt,name=RunningHost,proto3" json:"RunningHost,omitempty"`
	// Whether it is exposed with TLS or not
	RunningSecure bool `protobuf:"varint,4,opt,name=RunningSecure,proto3" json:"RunningSecure,omitempty"`
	// Port where this minio is bound
	RunningPort int32 `protobuf:"varint,5,opt,name=RunningPort,proto3" json:"RunningPort,omitempty"`
	// Api Key to access this object service
	ApiKey string `protobuf:"bytes,6,opt,name=ApiKey,proto3" json:"ApiKey,omitempty"`
	// Api Secret to access this object service
	ApiSecret string `protobuf:"bytes,7,opt,name=ApiSecret,proto3" json:"ApiSecret,omitempty"`
	// Url to get info about this object service
	EndpointUrl string `protobuf:"bytes,10,opt,name=EndpointUrl,proto3" json:"EndpointUrl,omitempty"`
	// Specific to Local storage type
	LocalFolder string `protobuf:"bytes,8,opt,name=LocalFolder,proto3" json:"LocalFolder,omitempty"`
	// Restrict this service to run on a given peer
	PeerAddress string `protobuf:"bytes,9,opt,name=PeerAddress,proto3" json:"PeerAddress,omitempty"`
	// Additional configs
	GatewayConfiguration map[string]string `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

Used a config storage for minio services

func (*MinioConfig) BuildUrl ¶ 

func (d *MinioConfig) BuildUrl() string

BuildUrl builds the url used for clients

func (*MinioConfig) ClientConfig ¶ 

func (d *MinioConfig) ClientConfig(ctx context.Context, p SecretProvider, agentName, agentVersion string) kv.Values

func (*MinioConfig) Descriptor deprecated 

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

Deprecated: Use MinioConfig.ProtoReflect.Descriptor instead.

func (*MinioConfig) GetApiKey ¶ 

func (x *MinioConfig) GetApiKey() string

func (*MinioConfig) GetApiSecret ¶ 

func (x *MinioConfig) GetApiSecret() string

func (*MinioConfig) GetEndpointUrl ¶ 

func (x *MinioConfig) GetEndpointUrl() string

func (*MinioConfig) GetGatewayConfiguration ¶ 

func (x *MinioConfig) GetGatewayConfiguration() map[string]string

func (*MinioConfig) GetLocalFolder ¶ 

func (x *MinioConfig) GetLocalFolder() string

func (*MinioConfig) GetName ¶ 

func (x *MinioConfig) GetName() string

func (*MinioConfig) GetPeerAddress ¶ 

func (x *MinioConfig) GetPeerAddress() string

func (*MinioConfig) GetRunningHost ¶ 

func (x *MinioConfig) GetRunningHost() string

func (*MinioConfig) GetRunningPort ¶ 

func (x *MinioConfig) GetRunningPort() int32

func (*MinioConfig) GetRunningSecure ¶ 

func (x *MinioConfig) GetRunningSecure() bool

func (*MinioConfig) GetStorageType ¶ 

func (x *MinioConfig) GetStorageType() StorageType

func (*MinioConfig) MarshalLogObject ¶ 

func (d *MinioConfig) MarshalLogObject(encoder zapcore.ObjectEncoder) error

MarshalLogObject implements custom marshalling for Minio, to avoid logging ApiKey

func (*MinioConfig) ProtoMessage ¶ 

func (*MinioConfig) ProtoMessage()

func (*MinioConfig) ProtoReflect ¶ 

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

func (*MinioConfig) Reset ¶ 

func (x *MinioConfig) Reset()

func (*MinioConfig) String ¶ 

func (x *MinioConfig) String() string

type ObjectsEndpointClient ¶ 

type ObjectsEndpointClient interface {
	GetMinioConfig(ctx context.Context, in *GetMinioConfigRequest, opts ...grpc.CallOption) (*GetMinioConfigResponse, error)
	StorageStats(ctx context.Context, in *StorageStatsRequest, opts ...grpc.CallOption) (*StorageStatsResponse, error)
}

ObjectsEndpointClient is the client API for ObjectsEndpoint 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 NewObjectsEndpointClient ¶ 

func NewObjectsEndpointClient(cc grpc.ClientConnInterface) ObjectsEndpointClient

type ObjectsEndpointServer ¶ 

type ObjectsEndpointServer interface {
	GetMinioConfig(context.Context, *GetMinioConfigRequest) (*GetMinioConfigResponse, error)
	StorageStats(context.Context, *StorageStatsRequest) (*StorageStatsResponse, error)
	// contains filtered or unexported methods
}

ObjectsEndpointServer is the server API for ObjectsEndpoint service. All implementations must embed UnimplementedObjectsEndpointServer for forward compatibility

type ResourceCleanerEndpointClient ¶ 

type ResourceCleanerEndpointClient interface {
	CleanResourcesBeforeDelete(ctx context.Context, in *CleanResourcesRequest, opts ...grpc.CallOption) (*CleanResourcesResponse, error)
}

ResourceCleanerEndpointClient is the client API for ResourceCleanerEndpoint 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 NewResourceCleanerEndpointClient ¶ 

func NewResourceCleanerEndpointClient(cc grpc.ClientConnInterface) ResourceCleanerEndpointClient

type ResourceCleanerEndpointServer ¶ 

type ResourceCleanerEndpointServer interface {
	CleanResourcesBeforeDelete(context.Context, *CleanResourcesRequest) (*CleanResourcesResponse, error)
	// contains filtered or unexported methods
}

ResourceCleanerEndpointServer is the server API for ResourceCleanerEndpoint service. All implementations must embed UnimplementedResourceCleanerEndpointServer for forward compatibility

type SecretProvider ¶ 

type SecretProvider func(ctx context.Context, uuid string) kv.Values

type StorageStatsRequest ¶ 

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

func (*StorageStatsRequest) Descriptor deprecated 

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

Deprecated: Use StorageStatsRequest.ProtoReflect.Descriptor instead.

func (*StorageStatsRequest) ProtoMessage ¶ 

func (*StorageStatsRequest) ProtoMessage()

func (*StorageStatsRequest) ProtoReflect ¶ 

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

func (*StorageStatsRequest) Reset ¶ 

func (x *StorageStatsRequest) Reset()

func (*StorageStatsRequest) String ¶ 

func (x *StorageStatsRequest) String() string

type StorageStatsResponse ¶ 

type StorageStatsResponse struct {
	Stats map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StorageStatsResponse) Descriptor deprecated 

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

Deprecated: Use StorageStatsResponse.ProtoReflect.Descriptor instead.

func (*StorageStatsResponse) GetStats ¶ 

func (x *StorageStatsResponse) GetStats() map[string]string

func (*StorageStatsResponse) ProtoMessage ¶ 

func (*StorageStatsResponse) ProtoMessage()

func (*StorageStatsResponse) ProtoReflect ¶ 

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

func (*StorageStatsResponse) Reset ¶ 

func (x *StorageStatsResponse) Reset()

func (*StorageStatsResponse) String ¶ 

func (x *StorageStatsResponse) String() string

type StorageType ¶ 

type StorageType int32

Type of Gateway 

const (
	StorageType_LOCAL StorageType = 0
	StorageType_S3    StorageType = 1
	StorageType_SMB   StorageType = 2
	StorageType_CELLS StorageType = 4
	StorageType_AZURE StorageType = 5
	StorageType_GCS   StorageType = 6
	StorageType_B2    StorageType = 7
	StorageType_MANTA StorageType = 8
	StorageType_SIA   StorageType = 9
)

func (StorageType) Descriptor ¶ 

func (StorageType) Descriptor() protoreflect.EnumDescriptor

func (StorageType) Enum ¶ 

func (x StorageType) Enum() *StorageType

func (StorageType) EnumDescriptor deprecated 

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

Deprecated: Use StorageType.Descriptor instead.

func (StorageType) Number ¶ 

func (x StorageType) Number() protoreflect.EnumNumber

func (StorageType) String ¶ 

func (x StorageType) String() string

func (StorageType) Type ¶ 

func (StorageType) Type() protoreflect.EnumType

type StorageTypeFilter ¶ 

type StorageTypeFilter int32
const (
	StorageTypeFilter_ANY     StorageTypeFilter = 0
	StorageTypeFilter_LOCALFS StorageTypeFilter = 1
	StorageTypeFilter_REMOTE  StorageTypeFilter = 2
)

func (StorageTypeFilter) Descriptor ¶ 

func (StorageTypeFilter) Descriptor() protoreflect.EnumDescriptor

func (StorageTypeFilter) Enum ¶ 

func (x StorageTypeFilter) Enum() *StorageTypeFilter

func (StorageTypeFilter) EnumDescriptor deprecated 

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

Deprecated: Use StorageTypeFilter.Descriptor instead.

func (StorageTypeFilter) Number ¶ 

func (x StorageTypeFilter) Number() protoreflect.EnumNumber

func (StorageTypeFilter) String ¶ 

func (x StorageTypeFilter) String() string

func (StorageTypeFilter) Type ¶ 

func (StorageTypeFilter) Type() protoreflect.EnumType

type UnimplementedDataSourceEndpointServer ¶ 

type UnimplementedDataSourceEndpointServer struct {
}

UnimplementedDataSourceEndpointServer must be embedded to have forward compatible implementations.

func (UnimplementedDataSourceEndpointServer) GetDataSourceConfig ¶ 

func (UnimplementedDataSourceEndpointServer) GetDataSourceConfig(context.Context, *GetDataSourceConfigRequest) (*GetDataSourceConfigResponse, error)

type UnimplementedObjectsEndpointServer ¶ 

type UnimplementedObjectsEndpointServer struct {
}

UnimplementedObjectsEndpointServer must be embedded to have forward compatible implementations.

func (UnimplementedObjectsEndpointServer) GetMinioConfig ¶ 

func (UnimplementedObjectsEndpointServer) GetMinioConfig(context.Context, *GetMinioConfigRequest) (*GetMinioConfigResponse, error)

func (UnimplementedObjectsEndpointServer) StorageStats ¶ 

func (UnimplementedObjectsEndpointServer) StorageStats(context.Context, *StorageStatsRequest) (*StorageStatsResponse, error)

type UnimplementedResourceCleanerEndpointServer ¶ 

type UnimplementedResourceCleanerEndpointServer struct {
}

UnimplementedResourceCleanerEndpointServer must be embedded to have forward compatible implementations.

func (UnimplementedResourceCleanerEndpointServer) CleanResourcesBeforeDelete ¶ 

func (UnimplementedResourceCleanerEndpointServer) CleanResourcesBeforeDelete(context.Context, *CleanResourcesRequest) (*CleanResourcesResponse, error)

type UnsafeDataSourceEndpointServer ¶ 

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

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

type UnsafeObjectsEndpointServer ¶ 

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

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

type UnsafeResourceCleanerEndpointServer ¶ 

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

UnsafeResourceCleanerEndpointServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ResourceCleanerEndpointServer 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.