object

package
v4.0.0-beta5 Latest Latest
Warning

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

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

Documentation

Index

Constants

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

	StorageKeyCustomEndpoint  = "customEndpoint"
	StorageKeyCustomRegion    = "customRegion"
	StorageKeyBucketsTags     = "bucketsTags"
	StorageKeyObjectsTags     = "objectsTags"
	StorageKeyNativeEtags     = "nativeEtags"
	StorageKeyBucketsRegexp   = "bucketsRegexp"
	StorageKeyReadonly        = "readOnly"
	StorageKeyJsonCredentials = "jsonCredentials"

	StorageKeyCellsInternal    = "cellsInternal"
	StorageKeyInitFromBucket   = "initFromBucket"
	StorageKeyInitFromSnapshot = "initFromSnapshot"
)

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) Descriptor deprecated

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

Deprecated: Use DataSource.ProtoReflect.Descriptor instead.

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

type DataSourceEndpointEnhancedServer

type DataSourceEndpointEnhancedServer map[string]NamedDataSourceEndpointServer

func (DataSourceEndpointEnhancedServer) GetDataSourceConfig

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 (*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) Enum

func (DataSourceEvent_DSEventType) EnumDescriptor deprecated

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

Deprecated: Use DataSourceEvent_DSEventType.Descriptor instead.

func (DataSourceEvent_DSEventType) Number

func (DataSourceEvent_DSEventType) String

func (DataSourceEvent_DSEventType) Type

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

func (x EncryptionMode) Enum() *EncryptionMode

func (EncryptionMode) EnumDescriptor deprecated

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

Deprecated: Use EncryptionMode.Descriptor instead.

func (EncryptionMode) Number

func (EncryptionMode) String

func (x EncryptionMode) String() string

func (EncryptionMode) Type

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 (*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 (*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) 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.

type ObjectsEndpointEnhancedServer

type ObjectsEndpointEnhancedServer map[string]NamedObjectsEndpointServer

func (ObjectsEndpointEnhancedServer) GetMinioConfig

func (ObjectsEndpointEnhancedServer) StorageStats

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.

type ResourceCleanerEndpointEnhancedServer

type ResourceCleanerEndpointEnhancedServer map[string]NamedResourceCleanerEndpointServer

func (ResourceCleanerEndpointEnhancedServer) CleanResourcesBeforeDelete

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

type StorageTypeFilter

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

func (StorageTypeFilter) Descriptor

func (StorageTypeFilter) Enum

func (StorageTypeFilter) EnumDescriptor deprecated

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

Deprecated: Use StorageTypeFilter.Descriptor instead.

func (StorageTypeFilter) Number

func (StorageTypeFilter) String

func (x StorageTypeFilter) String() string

func (StorageTypeFilter) Type

type UnimplementedDataSourceEndpointServer

type UnimplementedDataSourceEndpointServer struct {
}

UnimplementedDataSourceEndpointServer must be embedded to have forward compatible implementations.

func (UnimplementedDataSourceEndpointServer) GetDataSourceConfig

type UnimplementedObjectsEndpointServer

type UnimplementedObjectsEndpointServer struct {
}

UnimplementedObjectsEndpointServer must be embedded to have forward compatible implementations.

func (UnimplementedObjectsEndpointServer) GetMinioConfig

func (UnimplementedObjectsEndpointServer) StorageStats

type UnimplementedResourceCleanerEndpointServer

type UnimplementedResourceCleanerEndpointServer struct {
}

UnimplementedResourceCleanerEndpointServer must be embedded to have forward compatible implementations.

func (UnimplementedResourceCleanerEndpointServer) CleanResourcesBeforeDelete

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL