object

package
v1.2.1 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2018 License: AGPL-3.0 Imports: 7 Imported by: 131

Documentation

Overview

Package object is a generated protocol buffer package.

It is generated from these files: 

object.proto

It has these top-level messages: 

CleanResourcesRequest
CleanResourcesResponse
DataSource
MinioConfig
DataSourceEvent
GetMinioConfigRequest
GetMinioConfigResponse
GetDataSourceConfigRequest
GetDataSourceConfigResponse

Package object is a generated protocol buffer package.

It is generated from these files: 

object.proto

It has these top-level messages: 

CleanResourcesRequest
CleanResourcesResponse
DataSource
MinioConfig
DataSourceEvent
GetMinioConfigRequest
GetMinioConfigResponse
GetDataSourceConfigRequest
GetDataSourceConfigResponse

Index

Constants

This section is empty.

Variables

View Source 
var DataSourceEvent_DSEventType_name = map[int32]string{
	0: "CREATE",
	1: "UPDATE",
	2: "DELETE",
	3: "ENABLED",
	4: "DISABLED",
}
View Source 
var DataSourceEvent_DSEventType_value = map[string]int32{
	"CREATE":   0,
	"UPDATE":   1,
	"DELETE":   2,
	"ENABLED":  3,
	"DISABLED": 4,
}
View Source 
var EncryptionMode_name = map[int32]string{
	0: "CLEAR",
	1: "MASTER",
	2: "USER",
	3: "USER_PWD",
}
View Source 
var EncryptionMode_value = map[string]int32{
	"CLEAR":    0,
	"MASTER":   1,
	"USER":     2,
	"USER_PWD": 3,
}
View Source 
var StorageType_name = map[int32]string{
	0: "LOCAL",
	1: "S3",
	2: "SMB",
}
View Source 
var StorageType_value = map[string]int32{
	"LOCAL": 0,
	"S3":    1,
	"SMB":   2,
}

Functions

func RegisterDataSourceEndpointHandler 

func RegisterDataSourceEndpointHandler(s server.Server, hdlr DataSourceEndpointHandler, opts ...server.HandlerOption)

func RegisterObjectsEndpointHandler 

func RegisterObjectsEndpointHandler(s server.Server, hdlr ObjectsEndpointHandler, opts ...server.HandlerOption)

func RegisterResourceCleanerEndpointHandler 

func RegisterResourceCleanerEndpointHandler(s server.Server, hdlr ResourceCleanerEndpointHandler, opts ...server.HandlerOption)

Types

type CleanResourcesRequest 

type CleanResourcesRequest struct {
}

func (*CleanResourcesRequest) Descriptor 

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

func (*CleanResourcesRequest) ProtoMessage 

func (*CleanResourcesRequest) ProtoMessage()

func (*CleanResourcesRequest) Reset 

func (m *CleanResourcesRequest) Reset()

func (*CleanResourcesRequest) String 

func (m *CleanResourcesRequest) String() string

type CleanResourcesResponse 

type CleanResourcesResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
}

func (*CleanResourcesResponse) Descriptor 

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

func (*CleanResourcesResponse) GetMessage 

func (m *CleanResourcesResponse) GetMessage() string

func (*CleanResourcesResponse) GetSuccess 

func (m *CleanResourcesResponse) GetSuccess() bool

func (*CleanResourcesResponse) ProtoMessage 

func (*CleanResourcesResponse) ProtoMessage()

func (*CleanResourcesResponse) Reset 

func (m *CleanResourcesResponse) Reset()

func (*CleanResourcesResponse) String 

func (m *CleanResourcesResponse) String() string

type DataSource 

type DataSource struct {
	Name                    string            `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
	Disabled                bool              `protobuf:"varint,2,opt,name=Disabled" json:"Disabled,omitempty"`
	StorageType             StorageType       `protobuf:"varint,3,opt,name=StorageType,enum=object.StorageType" json:"StorageType,omitempty"`
	StorageConfiguration    map[string]string `` /* 160-byte string literal not displayed */
	ObjectsServiceName      string            `protobuf:"bytes,18,opt,name=ObjectsServiceName" json:"ObjectsServiceName,omitempty"`
	ObjectsHost             string            `protobuf:"bytes,12,opt,name=ObjectsHost" json:"ObjectsHost,omitempty"`
	ObjectsPort             int32             `protobuf:"varint,5,opt,name=ObjectsPort" json:"ObjectsPort,omitempty"`
	ObjectsSecure           bool              `protobuf:"varint,13,opt,name=ObjectsSecure" json:"ObjectsSecure,omitempty"`
	ObjectsBucket           string            `protobuf:"bytes,14,opt,name=ObjectsBucket" json:"ObjectsBucket,omitempty"`
	ObjectsBaseFolder       string            `protobuf:"bytes,15,opt,name=ObjectsBaseFolder" json:"ObjectsBaseFolder,omitempty"`
	ApiKey                  string            `protobuf:"bytes,16,opt,name=ApiKey" json:"ApiKey,omitempty"`
	ApiSecret               string            `protobuf:"bytes,17,opt,name=ApiSecret" json:"ApiSecret,omitempty"`
	PeerAddress             string            `protobuf:"bytes,19,opt,name=PeerAddress" json:"PeerAddress,omitempty"`
	Watch                   bool              `protobuf:"varint,6,opt,name=Watch" json:"Watch,omitempty"`
	EncryptionMode          EncryptionMode    `protobuf:"varint,7,opt,name=EncryptionMode,enum=object.EncryptionMode" json:"EncryptionMode,omitempty"`
	EncryptionKey           string            `protobuf:"bytes,8,opt,name=EncryptionKey" json:"EncryptionKey,omitempty"`
	VersioningPolicyName    string            `protobuf:"bytes,9,opt,name=VersioningPolicyName" json:"VersioningPolicyName,omitempty"`
	CreationDate            int32             `protobuf:"varint,10,opt,name=CreationDate" json:"CreationDate,omitempty"`
	LastSynchronizationDate int32             `protobuf:"varint,11,opt,name=LastSynchronizationDate" json:"LastSynchronizationDate,omitempty"`
}

DataSource Object description

func (*DataSource) BuildUrl 

func (d *DataSource) BuildUrl() string

Builds the url used for clients

func (*DataSource) CreateClient 

func (d *DataSource) CreateClient() (*minio.Core, error)

Creates a Minio.Core client from the datasource parameters

func (*DataSource) Descriptor 

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

func (*DataSource) GetApiKey 

func (m *DataSource) GetApiKey() string

func (*DataSource) GetApiSecret 

func (m *DataSource) GetApiSecret() string

func (*DataSource) GetCreationDate 

func (m *DataSource) GetCreationDate() int32

func (*DataSource) GetDisabled 

func (m *DataSource) GetDisabled() bool

func (*DataSource) GetEncryptionKey 

func (m *DataSource) GetEncryptionKey() string

func (*DataSource) GetEncryptionMode 

func (m *DataSource) GetEncryptionMode() EncryptionMode

func (*DataSource) GetLastSynchronizationDate 

func (m *DataSource) GetLastSynchronizationDate() int32

func (*DataSource) GetName 

func (m *DataSource) GetName() string

func (*DataSource) GetObjectsBaseFolder 

func (m *DataSource) GetObjectsBaseFolder() string

func (*DataSource) GetObjectsBucket 

func (m *DataSource) GetObjectsBucket() string

func (*DataSource) GetObjectsHost 

func (m *DataSource) GetObjectsHost() string

func (*DataSource) GetObjectsPort 

func (m *DataSource) GetObjectsPort() int32

func (*DataSource) GetObjectsSecure 

func (m *DataSource) GetObjectsSecure() bool

func (*DataSource) GetObjectsServiceName 

func (m *DataSource) GetObjectsServiceName() string

func (*DataSource) GetPeerAddress 

func (m *DataSource) GetPeerAddress() string

func (*DataSource) GetStorageConfiguration 

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

func (*DataSource) GetStorageType 

func (m *DataSource) GetStorageType() StorageType

func (*DataSource) GetVersioningPolicyName 

func (m *DataSource) GetVersioningPolicyName() string

func (*DataSource) GetWatch 

func (m *DataSource) GetWatch() bool

func (*DataSource) ProtoMessage 

func (*DataSource) ProtoMessage()

func (*DataSource) Reset 

func (m *DataSource) Reset()

func (*DataSource) String 

func (m *DataSource) String() string

type DataSourceEndpoint 

type DataSourceEndpoint struct {
	DataSourceEndpointHandler
}

func (*DataSourceEndpoint) GetDataSourceConfig 

func (h *DataSourceEndpoint) GetDataSourceConfig(ctx context.Context, in *GetDataSourceConfigRequest, out *GetDataSourceConfigResponse) error

type DataSourceEndpointClient 

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

func NewDataSourceEndpointClient 

func NewDataSourceEndpointClient(serviceName string, c client.Client) DataSourceEndpointClient

type DataSourceEndpointHandler 

type DataSourceEndpointHandler interface {
	GetDataSourceConfig(context.Context, *GetDataSourceConfigRequest, *GetDataSourceConfigResponse) error
}

type DataSourceEvent 

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

Used to dispatch some specific events accross services

func (*DataSourceEvent) Descriptor 

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

func (*DataSourceEvent) GetConfig 

func (m *DataSourceEvent) GetConfig() *DataSource

func (*DataSourceEvent) GetName 

func (m *DataSourceEvent) GetName() string

func (*DataSourceEvent) GetType 

func (m *DataSourceEvent) GetType() DataSourceEvent_DSEventType

func (*DataSourceEvent) ProtoMessage 

func (*DataSourceEvent) ProtoMessage()

func (*DataSourceEvent) Reset 

func (m *DataSourceEvent) Reset()

func (*DataSourceEvent) String 

func (m *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) EnumDescriptor 

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

func (DataSourceEvent_DSEventType) String 

func (x DataSourceEvent_DSEventType) 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) EnumDescriptor 

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

func (EncryptionMode) String 

func (x EncryptionMode) String() string

type GetDataSourceConfigRequest 

type GetDataSourceConfigRequest struct {
}

func (*GetDataSourceConfigRequest) Descriptor 

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

func (*GetDataSourceConfigRequest) ProtoMessage 

func (*GetDataSourceConfigRequest) ProtoMessage()

func (*GetDataSourceConfigRequest) Reset 

func (m *GetDataSourceConfigRequest) Reset()

func (*GetDataSourceConfigRequest) String 

func (m *GetDataSourceConfigRequest) String() string

type GetDataSourceConfigResponse 

type GetDataSourceConfigResponse struct {
	DataSource *DataSource `protobuf:"bytes,1,opt,name=DataSource" json:"DataSource,omitempty"`
}

func (*GetDataSourceConfigResponse) Descriptor 

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

func (*GetDataSourceConfigResponse) GetDataSource 

func (m *GetDataSourceConfigResponse) GetDataSource() *DataSource

func (*GetDataSourceConfigResponse) ProtoMessage 

func (*GetDataSourceConfigResponse) ProtoMessage()

func (*GetDataSourceConfigResponse) Reset 

func (m *GetDataSourceConfigResponse) Reset()

func (*GetDataSourceConfigResponse) String 

func (m *GetDataSourceConfigResponse) String() string

type GetMinioConfigRequest 

type GetMinioConfigRequest struct {
}

func (*GetMinioConfigRequest) Descriptor 

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

func (*GetMinioConfigRequest) ProtoMessage 

func (*GetMinioConfigRequest) ProtoMessage()

func (*GetMinioConfigRequest) Reset 

func (m *GetMinioConfigRequest) Reset()

func (*GetMinioConfigRequest) String 

func (m *GetMinioConfigRequest) String() string

type GetMinioConfigResponse 

type GetMinioConfigResponse struct {
	MinioConfig *MinioConfig `protobuf:"bytes,1,opt,name=MinioConfig" json:"MinioConfig,omitempty"`
}

func (*GetMinioConfigResponse) Descriptor 

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

func (*GetMinioConfigResponse) GetMinioConfig 

func (m *GetMinioConfigResponse) GetMinioConfig() *MinioConfig

func (*GetMinioConfigResponse) ProtoMessage 

func (*GetMinioConfigResponse) ProtoMessage()

func (*GetMinioConfigResponse) Reset 

func (m *GetMinioConfigResponse) Reset()

func (*GetMinioConfigResponse) String 

func (m *GetMinioConfigResponse) String() string

type MinioConfig 

type MinioConfig struct {
	Name          string      `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
	StorageType   StorageType `protobuf:"varint,2,opt,name=StorageType,enum=object.StorageType" json:"StorageType,omitempty"`
	RunningHost   string      `protobuf:"bytes,3,opt,name=RunningHost" json:"RunningHost,omitempty"`
	RunningSecure bool        `protobuf:"varint,4,opt,name=RunningSecure" json:"RunningSecure,omitempty"`
	RunningPort   int32       `protobuf:"varint,5,opt,name=RunningPort" json:"RunningPort,omitempty"`
	ApiKey        string      `protobuf:"bytes,6,opt,name=ApiKey" json:"ApiKey,omitempty"`
	ApiSecret     string      `protobuf:"bytes,7,opt,name=ApiSecret" json:"ApiSecret,omitempty"`
	EndpointUrl   string      `protobuf:"bytes,10,opt,name=EndpointUrl" json:"EndpointUrl,omitempty"`
	// Specific to Local storage type
	LocalFolder string `protobuf:"bytes,8,opt,name=LocalFolder" json:"LocalFolder,omitempty"`
	PeerAddress string `protobuf:"bytes,9,opt,name=PeerAddress" json:"PeerAddress,omitempty"`
}

Used a config storage for minio services

func (*MinioConfig) BuildUrl 

func (d *MinioConfig) BuildUrl() string

Builds the url used for clients

func (*MinioConfig) Descriptor 

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

func (*MinioConfig) GetApiKey 

func (m *MinioConfig) GetApiKey() string

func (*MinioConfig) GetApiSecret 

func (m *MinioConfig) GetApiSecret() string

func (*MinioConfig) GetEndpointUrl 

func (m *MinioConfig) GetEndpointUrl() string

func (*MinioConfig) GetLocalFolder 

func (m *MinioConfig) GetLocalFolder() string

func (*MinioConfig) GetName 

func (m *MinioConfig) GetName() string

func (*MinioConfig) GetPeerAddress 

func (m *MinioConfig) GetPeerAddress() string

func (*MinioConfig) GetRunningHost 

func (m *MinioConfig) GetRunningHost() string

func (*MinioConfig) GetRunningPort 

func (m *MinioConfig) GetRunningPort() int32

func (*MinioConfig) GetRunningSecure 

func (m *MinioConfig) GetRunningSecure() bool

func (*MinioConfig) GetStorageType 

func (m *MinioConfig) GetStorageType() StorageType

func (*MinioConfig) ProtoMessage 

func (*MinioConfig) ProtoMessage()

func (*MinioConfig) Reset 

func (m *MinioConfig) Reset()

func (*MinioConfig) String 

func (m *MinioConfig) String() string

type ObjectsEndpoint 

type ObjectsEndpoint struct {
	ObjectsEndpointHandler
}

func (*ObjectsEndpoint) GetMinioConfig 

func (h *ObjectsEndpoint) GetMinioConfig(ctx context.Context, in *GetMinioConfigRequest, out *GetMinioConfigResponse) error

type ObjectsEndpointClient 

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

func NewObjectsEndpointClient 

func NewObjectsEndpointClient(serviceName string, c client.Client) ObjectsEndpointClient

type ObjectsEndpointHandler 

type ObjectsEndpointHandler interface {
	GetMinioConfig(context.Context, *GetMinioConfigRequest, *GetMinioConfigResponse) error
}

type ResourceCleanerEndpoint 

type ResourceCleanerEndpoint struct {
	ResourceCleanerEndpointHandler
}

func (*ResourceCleanerEndpoint) CleanResourcesBeforeDelete 

func (h *ResourceCleanerEndpoint) CleanResourcesBeforeDelete(ctx context.Context, in *CleanResourcesRequest, out *CleanResourcesResponse) error

type ResourceCleanerEndpointClient 

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

func NewResourceCleanerEndpointClient 

func NewResourceCleanerEndpointClient(serviceName string, c client.Client) ResourceCleanerEndpointClient

type ResourceCleanerEndpointHandler 

type ResourceCleanerEndpointHandler interface {
	CleanResourcesBeforeDelete(context.Context, *CleanResourcesRequest, *CleanResourcesResponse) error
}

type StorageType 

type StorageType int32

Type of Gateway 

const (
	StorageType_LOCAL StorageType = 0
	StorageType_S3    StorageType = 1
	StorageType_SMB   StorageType = 2
)

func (StorageType) EnumDescriptor 

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

func (StorageType) String 

func (x StorageType) String() string

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.