object

package
v4.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 2024 License: AGPL-3.0 Imports: 19 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 DeregisterDataSourceEndpointEnhancedServer 

func DeregisterDataSourceEndpointEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterObjectsEndpointEnhancedServer 

func DeregisterObjectsEndpointEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterResourceCleanerEndpointEnhancedServer 

func DeregisterResourceCleanerEndpointEnhancedServer(s grpc.ServiceRegistrar, name string)

func RegisterDataSourceEndpointEnhancedServer 

func RegisterDataSourceEndpointEnhancedServer(s grpc.ServiceRegistrar, srv NamedDataSourceEndpointServer)

func RegisterDataSourceEndpointServer 

func RegisterDataSourceEndpointServer(s grpc.ServiceRegistrar, srv DataSourceEndpointServer)

func RegisterObjectsEndpointEnhancedServer 

func RegisterObjectsEndpointEnhancedServer(s grpc.ServiceRegistrar, srv NamedObjectsEndpointServer)

func RegisterObjectsEndpointServer 

func RegisterObjectsEndpointServer(s grpc.ServiceRegistrar, srv ObjectsEndpointServer)

func RegisterResourceCleanerEndpointEnhancedServer 

func RegisterResourceCleanerEndpointEnhancedServer(s grpc.ServiceRegistrar, srv NamedResourceCleanerEndpointServer)

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

func (*CleanResourcesRequest) Validate 

func (this *CleanResourcesRequest) Validate() error

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

func (*CleanResourcesResponse) Validate 

func (this *CleanResourcesResponse) Validate() error

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() configx.Values

func (*DataSource) ConfigurationByKey added in v4.0.6 

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 added in v4.0.3 

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 added in v4.0.1 

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

func (*DataSource) Validate 

func (this *DataSource) Validate() error

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 DataSourceEndpointEnhancedServer 

type DataSourceEndpointEnhancedServer map[string]NamedDataSourceEndpointServer

func (DataSourceEndpointEnhancedServer) GetDataSourceConfig 

func (m DataSourceEndpointEnhancedServer) GetDataSourceConfig(ctx context.Context, r *GetDataSourceConfigRequest) (*GetDataSourceConfigResponse, error)

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

func (*DataSourceEvent) Validate 

func (this *DataSourceEvent) Validate() error

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 {
	Name                      string            `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	IsDisabled                bool              `protobuf:"varint,2,opt,name=IsDisabled,proto3" json:"IsDisabled,omitempty"`
	StorageType               StorageTypeFilter `protobuf:"varint,3,opt,name=StorageType,proto3,enum=object.StorageTypeFilter" json:"StorageType,omitempty"`
	PeerAddress               string            `protobuf:"bytes,4,opt,name=PeerAddress,proto3" json:"PeerAddress,omitempty"`
	FlatStorage               bool              `protobuf:"varint,5,opt,name=FlatStorage,proto3" json:"FlatStorage,omitempty"`
	SkipSyncOnRestart         bool              `protobuf:"varint,6,opt,name=SkipSyncOnRestart,proto3" json:"SkipSyncOnRestart,omitempty"`
	IsVersioned               bool              `protobuf:"varint,9,opt,name=IsVersioned,proto3" json:"IsVersioned,omitempty"`
	IsEncrypted               bool              `protobuf:"varint,17,opt,name=IsEncrypted,proto3" json:"IsEncrypted,omitempty"`
	EncryptionMode            EncryptionMode    `protobuf:"varint,7,opt,name=EncryptionMode,proto3,enum=object.EncryptionMode" json:"EncryptionMode,omitempty"`
	EncryptionKey             string            `protobuf:"bytes,8,opt,name=EncryptionKey,proto3" json:"EncryptionKey,omitempty"`
	VersioningPolicyName      string            `protobuf:"bytes,10,opt,name=VersioningPolicyName,proto3" json:"VersioningPolicyName,omitempty"`
	StorageConfigurationName  string            `protobuf:"bytes,13,opt,name=StorageConfigurationName,proto3" json:"StorageConfigurationName,omitempty"`
	StorageConfigurationValue string            `protobuf:"bytes,14,opt,name=StorageConfigurationValue,proto3" json:"StorageConfigurationValue,omitempty"`
	ObjectServiceName         string            `protobuf:"bytes,15,opt,name=ObjectServiceName,proto3" json:"ObjectServiceName,omitempty"`
	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(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

func (*DataSourceSingleQuery) Validate 

func (this *DataSourceSingleQuery) Validate() error

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

func (*GetDataSourceConfigRequest) Validate 

func (this *GetDataSourceConfigRequest) Validate() error

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

func (*GetDataSourceConfigResponse) Validate 

func (this *GetDataSourceConfigResponse) Validate() error

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

func (*GetMinioConfigRequest) Validate 

func (this *GetMinioConfigRequest) Validate() error

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

func (*GetMinioConfigResponse) Validate 

func (this *GetMinioConfigResponse) Validate() error

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 added in v4.0.1 

func (d *MinioConfig) ClientConfig() configx.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

func (*MinioConfig) Validate 

func (this *MinioConfig) Validate() error

type NamedDataSourceEndpointServer 

type NamedDataSourceEndpointServer interface {
	DataSourceEndpointServer
	Name() string
}

type NamedObjectsEndpointServer 

type NamedObjectsEndpointServer interface {
	ObjectsEndpointServer
	Name() string
}

type NamedResourceCleanerEndpointServer 

type NamedResourceCleanerEndpointServer interface {
	ResourceCleanerEndpointServer
	Name() 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 ObjectsEndpointEnhancedServer 

type ObjectsEndpointEnhancedServer map[string]NamedObjectsEndpointServer

func (ObjectsEndpointEnhancedServer) GetMinioConfig 

func (m ObjectsEndpointEnhancedServer) GetMinioConfig(ctx context.Context, r *GetMinioConfigRequest) (*GetMinioConfigResponse, error)

func (ObjectsEndpointEnhancedServer) StorageStats 

func (m ObjectsEndpointEnhancedServer) StorageStats(ctx context.Context, r *StorageStatsRequest) (*StorageStatsResponse, error)

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 ResourceCleanerEndpointEnhancedServer 

type ResourceCleanerEndpointEnhancedServer map[string]NamedResourceCleanerEndpointServer

func (ResourceCleanerEndpointEnhancedServer) CleanResourcesBeforeDelete 

func (m ResourceCleanerEndpointEnhancedServer) CleanResourcesBeforeDelete(ctx context.Context, r *CleanResourcesRequest) (*CleanResourcesResponse, error)

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 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

func (*StorageStatsRequest) Validate 

func (this *StorageStatsRequest) Validate() error

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

func (*StorageStatsResponse) Validate 

func (this *StorageStatsResponse) Validate() error

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.