Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + var DataSourceEvent_DSEventType_name = map[int32]string + var DataSourceEvent_DSEventType_value = map[string]int32 + var EncryptionMode_name = map[int32]string + var EncryptionMode_value = map[string]int32 + var StorageType_name = map[int32]string + var StorageType_value = map[string]int32 + func RegisterDataSourceEndpointHandler(s server.Server, hdlr DataSourceEndpointHandler, opts ...server.HandlerOption) + func RegisterObjectsEndpointHandler(s server.Server, hdlr ObjectsEndpointHandler, opts ...server.HandlerOption) + func RegisterResourceCleanerEndpointHandler(s server.Server, hdlr ResourceCleanerEndpointHandler, ...) + type CleanResourcesRequest struct + func (*CleanResourcesRequest) Descriptor() ([]byte, []int) + func (*CleanResourcesRequest) ProtoMessage() + func (m *CleanResourcesRequest) Reset() + func (m *CleanResourcesRequest) String() string + func (this *CleanResourcesRequest) Validate() error + type CleanResourcesResponse struct + Message string + Success bool + func (*CleanResourcesResponse) Descriptor() ([]byte, []int) + func (*CleanResourcesResponse) ProtoMessage() + func (m *CleanResourcesResponse) GetMessage() string + func (m *CleanResourcesResponse) GetSuccess() bool + func (m *CleanResourcesResponse) Reset() + func (m *CleanResourcesResponse) String() string + func (this *CleanResourcesResponse) Validate() error + type DataSource struct + ApiKey string + ApiSecret string + CreationDate int32 + Disabled bool + EncryptionKey string + EncryptionMode EncryptionMode + LastSynchronizationDate int32 + Name string + ObjectsBaseFolder string + ObjectsBucket string + ObjectsHost string + ObjectsPort int32 + ObjectsSecure bool + ObjectsServiceName string + PeerAddress string + StorageConfiguration map[string]string + StorageType StorageType + VersioningPolicyName string + Watch bool + func (*DataSource) Descriptor() ([]byte, []int) + func (*DataSource) ProtoMessage() + func (d *DataSource) BuildUrl() string + func (d *DataSource) CreateClient() (*minio.Core, error) + func (m *DataSource) GetApiKey() string + func (m *DataSource) GetApiSecret() string + func (m *DataSource) GetCreationDate() int32 + func (m *DataSource) GetDisabled() bool + func (m *DataSource) GetEncryptionKey() string + func (m *DataSource) GetEncryptionMode() EncryptionMode + func (m *DataSource) GetLastSynchronizationDate() int32 + func (m *DataSource) GetName() string + func (m *DataSource) GetObjectsBaseFolder() string + func (m *DataSource) GetObjectsBucket() string + func (m *DataSource) GetObjectsHost() string + func (m *DataSource) GetObjectsPort() int32 + func (m *DataSource) GetObjectsSecure() bool + func (m *DataSource) GetObjectsServiceName() string + func (m *DataSource) GetPeerAddress() string + func (m *DataSource) GetStorageConfiguration() map[string]string + func (m *DataSource) GetStorageType() StorageType + func (m *DataSource) GetVersioningPolicyName() string + func (m *DataSource) GetWatch() bool + func (m *DataSource) Reset() + func (m *DataSource) String() string + func (this *DataSource) Validate() error + type DataSourceEndpoint struct + func (h *DataSourceEndpoint) GetDataSourceConfig(ctx context.Context, in *GetDataSourceConfigRequest, ...) error + type DataSourceEndpointClient interface + GetDataSourceConfig func(ctx context.Context, in *GetDataSourceConfigRequest, opts ...client.CallOption) (*GetDataSourceConfigResponse, error) + func NewDataSourceEndpointClient(serviceName string, c client.Client) DataSourceEndpointClient + type DataSourceEndpointHandler interface + GetDataSourceConfig func(context.Context, *GetDataSourceConfigRequest, *GetDataSourceConfigResponse) error + type DataSourceEvent struct + Config *DataSource + Name string + Type DataSourceEvent_DSEventType + func (*DataSourceEvent) Descriptor() ([]byte, []int) + func (*DataSourceEvent) ProtoMessage() + func (m *DataSourceEvent) GetConfig() *DataSource + func (m *DataSourceEvent) GetName() string + func (m *DataSourceEvent) GetType() DataSourceEvent_DSEventType + func (m *DataSourceEvent) Reset() + func (m *DataSourceEvent) String() string + func (this *DataSourceEvent) Validate() error + type DataSourceEvent_DSEventType int32 + const DataSourceEvent_CREATE + const DataSourceEvent_DELETE + const DataSourceEvent_DISABLED + const DataSourceEvent_ENABLED + const DataSourceEvent_UPDATE + func (DataSourceEvent_DSEventType) EnumDescriptor() ([]byte, []int) + func (x DataSourceEvent_DSEventType) String() string + type EncryptionMode int32 + const EncryptionMode_CLEAR + const EncryptionMode_MASTER + const EncryptionMode_USER + const EncryptionMode_USER_PWD + func (EncryptionMode) EnumDescriptor() ([]byte, []int) + func (x EncryptionMode) String() string + type GetDataSourceConfigRequest struct + func (*GetDataSourceConfigRequest) Descriptor() ([]byte, []int) + func (*GetDataSourceConfigRequest) ProtoMessage() + func (m *GetDataSourceConfigRequest) Reset() + func (m *GetDataSourceConfigRequest) String() string + func (this *GetDataSourceConfigRequest) Validate() error + type GetDataSourceConfigResponse struct + DataSource *DataSource + func (*GetDataSourceConfigResponse) Descriptor() ([]byte, []int) + func (*GetDataSourceConfigResponse) ProtoMessage() + func (m *GetDataSourceConfigResponse) GetDataSource() *DataSource + func (m *GetDataSourceConfigResponse) Reset() + func (m *GetDataSourceConfigResponse) String() string + func (this *GetDataSourceConfigResponse) Validate() error + type GetMinioConfigRequest struct + func (*GetMinioConfigRequest) Descriptor() ([]byte, []int) + func (*GetMinioConfigRequest) ProtoMessage() + func (m *GetMinioConfigRequest) Reset() + func (m *GetMinioConfigRequest) String() string + func (this *GetMinioConfigRequest) Validate() error + type GetMinioConfigResponse struct + MinioConfig *MinioConfig + func (*GetMinioConfigResponse) Descriptor() ([]byte, []int) + func (*GetMinioConfigResponse) ProtoMessage() + func (m *GetMinioConfigResponse) GetMinioConfig() *MinioConfig + func (m *GetMinioConfigResponse) Reset() + func (m *GetMinioConfigResponse) String() string + func (this *GetMinioConfigResponse) Validate() error + type MinioConfig struct + ApiKey string + ApiSecret string + EndpointUrl string + GatewayConfiguration map[string]string + LocalFolder string + Name string + PeerAddress string + RunningHost string + RunningPort int32 + RunningSecure bool + StorageType StorageType + func (*MinioConfig) Descriptor() ([]byte, []int) + func (*MinioConfig) ProtoMessage() + func (d *MinioConfig) BuildUrl() string + func (m *MinioConfig) GetApiKey() string + func (m *MinioConfig) GetApiSecret() string + func (m *MinioConfig) GetEndpointUrl() string + func (m *MinioConfig) GetGatewayConfiguration() map[string]string + func (m *MinioConfig) GetLocalFolder() string + func (m *MinioConfig) GetName() string + func (m *MinioConfig) GetPeerAddress() string + func (m *MinioConfig) GetRunningHost() string + func (m *MinioConfig) GetRunningPort() int32 + func (m *MinioConfig) GetRunningSecure() bool + func (m *MinioConfig) GetStorageType() StorageType + func (m *MinioConfig) Reset() + func (m *MinioConfig) String() string + func (this *MinioConfig) Validate() error + type ObjectsEndpoint struct + func (h *ObjectsEndpoint) GetMinioConfig(ctx context.Context, in *GetMinioConfigRequest, out *GetMinioConfigResponse) error + type ObjectsEndpointClient interface + GetMinioConfig func(ctx context.Context, in *GetMinioConfigRequest, opts ...client.CallOption) (*GetMinioConfigResponse, error) + func NewObjectsEndpointClient(serviceName string, c client.Client) ObjectsEndpointClient + type ObjectsEndpointHandler interface + GetMinioConfig func(context.Context, *GetMinioConfigRequest, *GetMinioConfigResponse) error + type ResourceCleanerEndpoint struct + func (h *ResourceCleanerEndpoint) CleanResourcesBeforeDelete(ctx context.Context, in *CleanResourcesRequest, out *CleanResourcesResponse) error + type ResourceCleanerEndpointClient interface + CleanResourcesBeforeDelete func(ctx context.Context, in *CleanResourcesRequest, opts ...client.CallOption) (*CleanResourcesResponse, error) + func NewResourceCleanerEndpointClient(serviceName string, c client.Client) ResourceCleanerEndpointClient + type ResourceCleanerEndpointHandler interface + CleanResourcesBeforeDelete func(context.Context, *CleanResourcesRequest, *CleanResourcesResponse) error + type StorageType int32 + const StorageType_AZURE + const StorageType_B2 + const StorageType_CELLS + const StorageType_GCS + const StorageType_LOCAL + const StorageType_MANTA + const StorageType_S3 + const StorageType_SIA + const StorageType_SMB + func (StorageType) EnumDescriptor() ([]byte, []int) + func (x StorageType) String() string Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020