generated

package
v0.10.0-beta.1 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation ¶

Overview ¶

Package generated is a generated protocol buffer package.

It is generated from these files: 

BackupItemAction.proto
BlockStore.proto
ObjectStore.proto
PluginLister.proto
RestoreItemAction.proto
Shared.proto

It has these top-level messages: 

ExecuteRequest
ExecuteResponse
ResourceIdentifier
CreateVolumeRequest
CreateVolumeResponse
GetVolumeInfoRequest
GetVolumeInfoResponse
CreateSnapshotRequest
CreateSnapshotResponse
DeleteSnapshotRequest
GetVolumeIDRequest
GetVolumeIDResponse
SetVolumeIDRequest
SetVolumeIDResponse
PutObjectRequest
GetObjectRequest
Bytes
ListCommonPrefixesRequest
ListCommonPrefixesResponse
ListObjectsRequest
ListObjectsResponse
DeleteObjectRequest
CreateSignedURLRequest
CreateSignedURLResponse
PluginIdentifier
ListPluginsResponse
RestoreExecuteRequest
RestoreExecuteResponse
Empty
InitRequest
AppliesToRequest
AppliesToResponse

Index ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func RegisterBackupItemActionServer ¶ 

func RegisterBackupItemActionServer(s *grpc.Server, srv BackupItemActionServer)

func RegisterBlockStoreServer ¶ 

func RegisterBlockStoreServer(s *grpc.Server, srv BlockStoreServer)

func RegisterObjectStoreServer ¶ 

func RegisterObjectStoreServer(s *grpc.Server, srv ObjectStoreServer)

func RegisterPluginListerServer ¶ added in v0.10.0 

func RegisterPluginListerServer(s *grpc.Server, srv PluginListerServer)

func RegisterRestoreItemActionServer ¶ 

func RegisterRestoreItemActionServer(s *grpc.Server, srv RestoreItemActionServer)

Types ¶

type AppliesToRequest ¶ added in v0.10.0 

type AppliesToRequest struct {
	Plugin string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
}

func (*AppliesToRequest) Descriptor ¶ added in v0.10.0 

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

func (*AppliesToRequest) GetPlugin ¶ added in v0.10.0 

func (m *AppliesToRequest) GetPlugin() string

func (*AppliesToRequest) ProtoMessage ¶ added in v0.10.0 

func (*AppliesToRequest) ProtoMessage()

func (*AppliesToRequest) Reset ¶ added in v0.10.0 

func (m *AppliesToRequest) Reset()

func (*AppliesToRequest) String ¶ added in v0.10.0 

func (m *AppliesToRequest) String() string

type AppliesToResponse ¶ 

type AppliesToResponse struct {
	IncludedNamespaces []string `protobuf:"bytes,1,rep,name=includedNamespaces" json:"includedNamespaces,omitempty"`
	ExcludedNamespaces []string `protobuf:"bytes,2,rep,name=excludedNamespaces" json:"excludedNamespaces,omitempty"`
	IncludedResources  []string `protobuf:"bytes,3,rep,name=includedResources" json:"includedResources,omitempty"`
	ExcludedResources  []string `protobuf:"bytes,4,rep,name=excludedResources" json:"excludedResources,omitempty"`
	Selector           string   `protobuf:"bytes,5,opt,name=selector" json:"selector,omitempty"`
}

func (*AppliesToResponse) Descriptor ¶ 

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

func (*AppliesToResponse) GetExcludedNamespaces ¶ 

func (m *AppliesToResponse) GetExcludedNamespaces() []string

func (*AppliesToResponse) GetExcludedResources ¶ 

func (m *AppliesToResponse) GetExcludedResources() []string

func (*AppliesToResponse) GetIncludedNamespaces ¶ 

func (m *AppliesToResponse) GetIncludedNamespaces() []string

func (*AppliesToResponse) GetIncludedResources ¶ 

func (m *AppliesToResponse) GetIncludedResources() []string

func (*AppliesToResponse) GetSelector ¶ 

func (m *AppliesToResponse) GetSelector() string

func (*AppliesToResponse) ProtoMessage ¶ 

func (*AppliesToResponse) ProtoMessage()

func (*AppliesToResponse) Reset ¶ 

func (m *AppliesToResponse) Reset()

func (*AppliesToResponse) String ¶ 

func (m *AppliesToResponse) String() string

type BackupItemActionClient ¶ 

type BackupItemActionClient interface {
	AppliesTo(ctx context.Context, in *AppliesToRequest, opts ...grpc.CallOption) (*AppliesToResponse, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
}

func NewBackupItemActionClient ¶ 

func NewBackupItemActionClient(cc *grpc.ClientConn) BackupItemActionClient

type BackupItemActionServer ¶ 

type BackupItemActionServer interface {
	AppliesTo(context.Context, *AppliesToRequest) (*AppliesToResponse, error)
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
}

type BlockStoreClient ¶ 

type BlockStoreClient interface {
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*Empty, error)
	CreateVolumeFromSnapshot(ctx context.Context, in *CreateVolumeRequest, opts ...grpc.CallOption) (*CreateVolumeResponse, error)
	GetVolumeInfo(ctx context.Context, in *GetVolumeInfoRequest, opts ...grpc.CallOption) (*GetVolumeInfoResponse, error)
	CreateSnapshot(ctx context.Context, in *CreateSnapshotRequest, opts ...grpc.CallOption) (*CreateSnapshotResponse, error)
	DeleteSnapshot(ctx context.Context, in *DeleteSnapshotRequest, opts ...grpc.CallOption) (*Empty, error)
	GetVolumeID(ctx context.Context, in *GetVolumeIDRequest, opts ...grpc.CallOption) (*GetVolumeIDResponse, error)
	SetVolumeID(ctx context.Context, in *SetVolumeIDRequest, opts ...grpc.CallOption) (*SetVolumeIDResponse, error)
}

func NewBlockStoreClient ¶ 

func NewBlockStoreClient(cc *grpc.ClientConn) BlockStoreClient

type BlockStoreServer ¶ 

type BlockStoreServer interface {
	Init(context.Context, *InitRequest) (*Empty, error)
	CreateVolumeFromSnapshot(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)
	GetVolumeInfo(context.Context, *GetVolumeInfoRequest) (*GetVolumeInfoResponse, error)
	CreateSnapshot(context.Context, *CreateSnapshotRequest) (*CreateSnapshotResponse, error)
	DeleteSnapshot(context.Context, *DeleteSnapshotRequest) (*Empty, error)
	GetVolumeID(context.Context, *GetVolumeIDRequest) (*GetVolumeIDResponse, error)
	SetVolumeID(context.Context, *SetVolumeIDRequest) (*SetVolumeIDResponse, error)
}

type Bytes ¶ 

type Bytes struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Bytes) Descriptor ¶ 

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

func (*Bytes) GetData ¶ 

func (m *Bytes) GetData() []byte

func (*Bytes) ProtoMessage ¶ 

func (*Bytes) ProtoMessage()

func (*Bytes) Reset ¶ 

func (m *Bytes) Reset()

func (*Bytes) String ¶ 

func (m *Bytes) String() string

type CreateSignedURLRequest ¶ 

type CreateSignedURLRequest struct {
	Plugin string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	Bucket string `protobuf:"bytes,2,opt,name=bucket" json:"bucket,omitempty"`
	Key    string `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"`
	Ttl    int64  `protobuf:"varint,4,opt,name=ttl" json:"ttl,omitempty"`
}

func (*CreateSignedURLRequest) Descriptor ¶ 

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

func (*CreateSignedURLRequest) GetBucket ¶ 

func (m *CreateSignedURLRequest) GetBucket() string

func (*CreateSignedURLRequest) GetKey ¶ 

func (m *CreateSignedURLRequest) GetKey() string

func (*CreateSignedURLRequest) GetPlugin ¶ added in v0.10.0 

func (m *CreateSignedURLRequest) GetPlugin() string

func (*CreateSignedURLRequest) GetTtl ¶ 

func (m *CreateSignedURLRequest) GetTtl() int64

func (*CreateSignedURLRequest) ProtoMessage ¶ 

func (*CreateSignedURLRequest) ProtoMessage()

func (*CreateSignedURLRequest) Reset ¶ 

func (m *CreateSignedURLRequest) Reset()

func (*CreateSignedURLRequest) String ¶ 

func (m *CreateSignedURLRequest) String() string

type CreateSignedURLResponse ¶ 

type CreateSignedURLResponse struct {
	Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
}

func (*CreateSignedURLResponse) Descriptor ¶ 

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

func (*CreateSignedURLResponse) GetUrl ¶ 

func (m *CreateSignedURLResponse) GetUrl() string

func (*CreateSignedURLResponse) ProtoMessage ¶ 

func (*CreateSignedURLResponse) ProtoMessage()

func (*CreateSignedURLResponse) Reset ¶ 

func (m *CreateSignedURLResponse) Reset()

func (*CreateSignedURLResponse) String ¶ 

func (m *CreateSignedURLResponse) String() string

type CreateSnapshotRequest ¶ 

type CreateSnapshotRequest struct {
	Plugin   string            `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	VolumeID string            `protobuf:"bytes,2,opt,name=volumeID" json:"volumeID,omitempty"`
	VolumeAZ string            `protobuf:"bytes,3,opt,name=volumeAZ" json:"volumeAZ,omitempty"`
	Tags     map[string]string `` /* 128-byte string literal not displayed */
}

func (*CreateSnapshotRequest) Descriptor ¶ 

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

func (*CreateSnapshotRequest) GetPlugin ¶ added in v0.10.0 

func (m *CreateSnapshotRequest) GetPlugin() string

func (*CreateSnapshotRequest) GetTags ¶ 

func (m *CreateSnapshotRequest) GetTags() map[string]string

func (*CreateSnapshotRequest) GetVolumeAZ ¶ 

func (m *CreateSnapshotRequest) GetVolumeAZ() string

func (*CreateSnapshotRequest) GetVolumeID ¶ 

func (m *CreateSnapshotRequest) GetVolumeID() string

func (*CreateSnapshotRequest) ProtoMessage ¶ 

func (*CreateSnapshotRequest) ProtoMessage()

func (*CreateSnapshotRequest) Reset ¶ 

func (m *CreateSnapshotRequest) Reset()

func (*CreateSnapshotRequest) String ¶ 

func (m *CreateSnapshotRequest) String() string

type CreateSnapshotResponse ¶ 

type CreateSnapshotResponse struct {
	SnapshotID string `protobuf:"bytes,1,opt,name=snapshotID" json:"snapshotID,omitempty"`
}

func (*CreateSnapshotResponse) Descriptor ¶ 

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

func (*CreateSnapshotResponse) GetSnapshotID ¶ 

func (m *CreateSnapshotResponse) GetSnapshotID() string

func (*CreateSnapshotResponse) ProtoMessage ¶ 

func (*CreateSnapshotResponse) ProtoMessage()

func (*CreateSnapshotResponse) Reset ¶ 

func (m *CreateSnapshotResponse) Reset()

func (*CreateSnapshotResponse) String ¶ 

func (m *CreateSnapshotResponse) String() string

type CreateVolumeRequest ¶ 

type CreateVolumeRequest struct {
	Plugin     string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	SnapshotID string `protobuf:"bytes,2,opt,name=snapshotID" json:"snapshotID,omitempty"`
	VolumeType string `protobuf:"bytes,3,opt,name=volumeType" json:"volumeType,omitempty"`
	VolumeAZ   string `protobuf:"bytes,4,opt,name=volumeAZ" json:"volumeAZ,omitempty"`
	Iops       int64  `protobuf:"varint,5,opt,name=iops" json:"iops,omitempty"`
}

func (*CreateVolumeRequest) Descriptor ¶ 

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

func (*CreateVolumeRequest) GetIops ¶ 

func (m *CreateVolumeRequest) GetIops() int64

func (*CreateVolumeRequest) GetPlugin ¶ added in v0.10.0 

func (m *CreateVolumeRequest) GetPlugin() string

func (*CreateVolumeRequest) GetSnapshotID ¶ 

func (m *CreateVolumeRequest) GetSnapshotID() string

func (*CreateVolumeRequest) GetVolumeAZ ¶ 

func (m *CreateVolumeRequest) GetVolumeAZ() string

func (*CreateVolumeRequest) GetVolumeType ¶ 

func (m *CreateVolumeRequest) GetVolumeType() string

func (*CreateVolumeRequest) ProtoMessage ¶ 

func (*CreateVolumeRequest) ProtoMessage()

func (*CreateVolumeRequest) Reset ¶ 

func (m *CreateVolumeRequest) Reset()

func (*CreateVolumeRequest) String ¶ 

func (m *CreateVolumeRequest) String() string

type CreateVolumeResponse ¶ 

type CreateVolumeResponse struct {
	VolumeID string `protobuf:"bytes,1,opt,name=volumeID" json:"volumeID,omitempty"`
}

func (*CreateVolumeResponse) Descriptor ¶ 

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

func (*CreateVolumeResponse) GetVolumeID ¶ 

func (m *CreateVolumeResponse) GetVolumeID() string

func (*CreateVolumeResponse) ProtoMessage ¶ 

func (*CreateVolumeResponse) ProtoMessage()

func (*CreateVolumeResponse) Reset ¶ 

func (m *CreateVolumeResponse) Reset()

func (*CreateVolumeResponse) String ¶ 

func (m *CreateVolumeResponse) String() string

type DeleteObjectRequest ¶ 

type DeleteObjectRequest struct {
	Plugin string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	Bucket string `protobuf:"bytes,2,opt,name=bucket" json:"bucket,omitempty"`
	Key    string `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"`
}

func (*DeleteObjectRequest) Descriptor ¶ 

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

func (*DeleteObjectRequest) GetBucket ¶ 

func (m *DeleteObjectRequest) GetBucket() string

func (*DeleteObjectRequest) GetKey ¶ 

func (m *DeleteObjectRequest) GetKey() string

func (*DeleteObjectRequest) GetPlugin ¶ added in v0.10.0 

func (m *DeleteObjectRequest) GetPlugin() string

func (*DeleteObjectRequest) ProtoMessage ¶ 

func (*DeleteObjectRequest) ProtoMessage()

func (*DeleteObjectRequest) Reset ¶ 

func (m *DeleteObjectRequest) Reset()

func (*DeleteObjectRequest) String ¶ 

func (m *DeleteObjectRequest) String() string

type DeleteSnapshotRequest ¶ 

type DeleteSnapshotRequest struct {
	Plugin     string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	SnapshotID string `protobuf:"bytes,2,opt,name=snapshotID" json:"snapshotID,omitempty"`
}

func (*DeleteSnapshotRequest) Descriptor ¶ 

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

func (*DeleteSnapshotRequest) GetPlugin ¶ added in v0.10.0 

func (m *DeleteSnapshotRequest) GetPlugin() string

func (*DeleteSnapshotRequest) GetSnapshotID ¶ 

func (m *DeleteSnapshotRequest) GetSnapshotID() string

func (*DeleteSnapshotRequest) ProtoMessage ¶ 

func (*DeleteSnapshotRequest) ProtoMessage()

func (*DeleteSnapshotRequest) Reset ¶ 

func (m *DeleteSnapshotRequest) Reset()

func (*DeleteSnapshotRequest) String ¶ 

func (m *DeleteSnapshotRequest) String() string

type Empty ¶ 

type Empty struct {
}

func (*Empty) Descriptor ¶ 

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

func (*Empty) ProtoMessage ¶ 

func (*Empty) ProtoMessage()

func (*Empty) Reset ¶ 

func (m *Empty) Reset()

func (*Empty) String ¶ 

func (m *Empty) String() string

type ExecuteRequest ¶ 

type ExecuteRequest struct {
	Plugin string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	Item   []byte `protobuf:"bytes,2,opt,name=item,proto3" json:"item,omitempty"`
	Backup []byte `protobuf:"bytes,3,opt,name=backup,proto3" json:"backup,omitempty"`
}

func (*ExecuteRequest) Descriptor ¶ 

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

func (*ExecuteRequest) GetBackup ¶ 

func (m *ExecuteRequest) GetBackup() []byte

func (*ExecuteRequest) GetItem ¶ 

func (m *ExecuteRequest) GetItem() []byte

func (*ExecuteRequest) GetPlugin ¶ added in v0.10.0 

func (m *ExecuteRequest) GetPlugin() string

func (*ExecuteRequest) ProtoMessage ¶ 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset ¶ 

func (m *ExecuteRequest) Reset()

func (*ExecuteRequest) String ¶ 

func (m *ExecuteRequest) String() string

type ExecuteResponse ¶ 

type ExecuteResponse struct {
	Item            []byte                `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	AdditionalItems []*ResourceIdentifier `protobuf:"bytes,2,rep,name=additionalItems" json:"additionalItems,omitempty"`
}

func (*ExecuteResponse) Descriptor ¶ 

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

func (*ExecuteResponse) GetAdditionalItems ¶ 

func (m *ExecuteResponse) GetAdditionalItems() []*ResourceIdentifier

func (*ExecuteResponse) GetItem ¶ 

func (m *ExecuteResponse) GetItem() []byte

func (*ExecuteResponse) ProtoMessage ¶ 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) Reset ¶ 

func (m *ExecuteResponse) Reset()

func (*ExecuteResponse) String ¶ 

func (m *ExecuteResponse) String() string

type GetObjectRequest ¶ 

type GetObjectRequest struct {
	Plugin string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	Bucket string `protobuf:"bytes,2,opt,name=bucket" json:"bucket,omitempty"`
	Key    string `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"`
}

func (*GetObjectRequest) Descriptor ¶ 

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

func (*GetObjectRequest) GetBucket ¶ 

func (m *GetObjectRequest) GetBucket() string

func (*GetObjectRequest) GetKey ¶ 

func (m *GetObjectRequest) GetKey() string

func (*GetObjectRequest) GetPlugin ¶ added in v0.10.0 

func (m *GetObjectRequest) GetPlugin() string

func (*GetObjectRequest) ProtoMessage ¶ 

func (*GetObjectRequest) ProtoMessage()

func (*GetObjectRequest) Reset ¶ 

func (m *GetObjectRequest) Reset()

func (*GetObjectRequest) String ¶ 

func (m *GetObjectRequest) String() string

type GetVolumeIDRequest ¶ 

type GetVolumeIDRequest struct {
	Plugin           string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	PersistentVolume []byte `protobuf:"bytes,2,opt,name=persistentVolume,proto3" json:"persistentVolume,omitempty"`
}

func (*GetVolumeIDRequest) Descriptor ¶ 

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

func (*GetVolumeIDRequest) GetPersistentVolume ¶ 

func (m *GetVolumeIDRequest) GetPersistentVolume() []byte

func (*GetVolumeIDRequest) GetPlugin ¶ added in v0.10.0 

func (m *GetVolumeIDRequest) GetPlugin() string

func (*GetVolumeIDRequest) ProtoMessage ¶ 

func (*GetVolumeIDRequest) ProtoMessage()

func (*GetVolumeIDRequest) Reset ¶ 

func (m *GetVolumeIDRequest) Reset()

func (*GetVolumeIDRequest) String ¶ 

func (m *GetVolumeIDRequest) String() string

type GetVolumeIDResponse ¶ 

type GetVolumeIDResponse struct {
	VolumeID string `protobuf:"bytes,1,opt,name=volumeID" json:"volumeID,omitempty"`
}

func (*GetVolumeIDResponse) Descriptor ¶ 

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

func (*GetVolumeIDResponse) GetVolumeID ¶ 

func (m *GetVolumeIDResponse) GetVolumeID() string

func (*GetVolumeIDResponse) ProtoMessage ¶ 

func (*GetVolumeIDResponse) ProtoMessage()

func (*GetVolumeIDResponse) Reset ¶ 

func (m *GetVolumeIDResponse) Reset()

func (*GetVolumeIDResponse) String ¶ 

func (m *GetVolumeIDResponse) String() string

type GetVolumeInfoRequest ¶ 

type GetVolumeInfoRequest struct {
	Plugin   string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	VolumeID string `protobuf:"bytes,2,opt,name=volumeID" json:"volumeID,omitempty"`
	VolumeAZ string `protobuf:"bytes,3,opt,name=volumeAZ" json:"volumeAZ,omitempty"`
}

func (*GetVolumeInfoRequest) Descriptor ¶ 

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

func (*GetVolumeInfoRequest) GetPlugin ¶ added in v0.10.0 

func (m *GetVolumeInfoRequest) GetPlugin() string

func (*GetVolumeInfoRequest) GetVolumeAZ ¶ 

func (m *GetVolumeInfoRequest) GetVolumeAZ() string

func (*GetVolumeInfoRequest) GetVolumeID ¶ 

func (m *GetVolumeInfoRequest) GetVolumeID() string

func (*GetVolumeInfoRequest) ProtoMessage ¶ 

func (*GetVolumeInfoRequest) ProtoMessage()

func (*GetVolumeInfoRequest) Reset ¶ 

func (m *GetVolumeInfoRequest) Reset()

func (*GetVolumeInfoRequest) String ¶ 

func (m *GetVolumeInfoRequest) String() string

type GetVolumeInfoResponse ¶ 

type GetVolumeInfoResponse struct {
	VolumeType string `protobuf:"bytes,1,opt,name=volumeType" json:"volumeType,omitempty"`
	Iops       int64  `protobuf:"varint,2,opt,name=iops" json:"iops,omitempty"`
}

func (*GetVolumeInfoResponse) Descriptor ¶ 

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

func (*GetVolumeInfoResponse) GetIops ¶ 

func (m *GetVolumeInfoResponse) GetIops() int64

func (*GetVolumeInfoResponse) GetVolumeType ¶ 

func (m *GetVolumeInfoResponse) GetVolumeType() string

func (*GetVolumeInfoResponse) ProtoMessage ¶ 

func (*GetVolumeInfoResponse) ProtoMessage()

func (*GetVolumeInfoResponse) Reset ¶ 

func (m *GetVolumeInfoResponse) Reset()

func (*GetVolumeInfoResponse) String ¶ 

func (m *GetVolumeInfoResponse) String() string

type InitRequest ¶ 

type InitRequest struct {
	Plugin string            `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	Config map[string]string `` /* 132-byte string literal not displayed */
}

func (*InitRequest) Descriptor ¶ 

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

func (*InitRequest) GetConfig ¶ 

func (m *InitRequest) GetConfig() map[string]string

func (*InitRequest) GetPlugin ¶ added in v0.10.0 

func (m *InitRequest) GetPlugin() string

func (*InitRequest) ProtoMessage ¶ 

func (*InitRequest) ProtoMessage()

func (*InitRequest) Reset ¶ 

func (m *InitRequest) Reset()

func (*InitRequest) String ¶ 

func (m *InitRequest) String() string

type ListCommonPrefixesRequest ¶ 

type ListCommonPrefixesRequest struct {
	Plugin    string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	Bucket    string `protobuf:"bytes,2,opt,name=bucket" json:"bucket,omitempty"`
	Delimiter string `protobuf:"bytes,3,opt,name=delimiter" json:"delimiter,omitempty"`
	Prefix    string `protobuf:"bytes,4,opt,name=prefix" json:"prefix,omitempty"`
}

func (*ListCommonPrefixesRequest) Descriptor ¶ 

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

func (*ListCommonPrefixesRequest) GetBucket ¶ 

func (m *ListCommonPrefixesRequest) GetBucket() string

func (*ListCommonPrefixesRequest) GetDelimiter ¶ 

func (m *ListCommonPrefixesRequest) GetDelimiter() string

func (*ListCommonPrefixesRequest) GetPlugin ¶ added in v0.10.0 

func (m *ListCommonPrefixesRequest) GetPlugin() string

func (*ListCommonPrefixesRequest) GetPrefix ¶ added in v0.10.0 

func (m *ListCommonPrefixesRequest) GetPrefix() string

func (*ListCommonPrefixesRequest) ProtoMessage ¶ 

func (*ListCommonPrefixesRequest) ProtoMessage()

func (*ListCommonPrefixesRequest) Reset ¶ 

func (m *ListCommonPrefixesRequest) Reset()

func (*ListCommonPrefixesRequest) String ¶ 

func (m *ListCommonPrefixesRequest) String() string

type ListCommonPrefixesResponse ¶ 

type ListCommonPrefixesResponse struct {
	Prefixes []string `protobuf:"bytes,1,rep,name=prefixes" json:"prefixes,omitempty"`
}

func (*ListCommonPrefixesResponse) Descriptor ¶ 

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

func (*ListCommonPrefixesResponse) GetPrefixes ¶ 

func (m *ListCommonPrefixesResponse) GetPrefixes() []string

func (*ListCommonPrefixesResponse) ProtoMessage ¶ 

func (*ListCommonPrefixesResponse) ProtoMessage()

func (*ListCommonPrefixesResponse) Reset ¶ 

func (m *ListCommonPrefixesResponse) Reset()

func (*ListCommonPrefixesResponse) String ¶ 

func (m *ListCommonPrefixesResponse) String() string

type ListObjectsRequest ¶ 

type ListObjectsRequest struct {
	Plugin string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	Bucket string `protobuf:"bytes,2,opt,name=bucket" json:"bucket,omitempty"`
	Prefix string `protobuf:"bytes,3,opt,name=prefix" json:"prefix,omitempty"`
}

func (*ListObjectsRequest) Descriptor ¶ 

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

func (*ListObjectsRequest) GetBucket ¶ 

func (m *ListObjectsRequest) GetBucket() string

func (*ListObjectsRequest) GetPlugin ¶ added in v0.10.0 

func (m *ListObjectsRequest) GetPlugin() string

func (*ListObjectsRequest) GetPrefix ¶ 

func (m *ListObjectsRequest) GetPrefix() string

func (*ListObjectsRequest) ProtoMessage ¶ 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) Reset ¶ 

func (m *ListObjectsRequest) Reset()

func (*ListObjectsRequest) String ¶ 

func (m *ListObjectsRequest) String() string

type ListObjectsResponse ¶ 

type ListObjectsResponse struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
}

func (*ListObjectsResponse) Descriptor ¶ 

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

func (*ListObjectsResponse) GetKeys ¶ 

func (m *ListObjectsResponse) GetKeys() []string

func (*ListObjectsResponse) ProtoMessage ¶ 

func (*ListObjectsResponse) ProtoMessage()

func (*ListObjectsResponse) Reset ¶ 

func (m *ListObjectsResponse) Reset()

func (*ListObjectsResponse) String ¶ 

func (m *ListObjectsResponse) String() string

type ListPluginsResponse ¶ added in v0.10.0 

type ListPluginsResponse struct {
	Plugins []*PluginIdentifier `protobuf:"bytes,1,rep,name=plugins" json:"plugins,omitempty"`
}

func (*ListPluginsResponse) Descriptor ¶ added in v0.10.0 

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

func (*ListPluginsResponse) GetPlugins ¶ added in v0.10.0 

func (m *ListPluginsResponse) GetPlugins() []*PluginIdentifier

func (*ListPluginsResponse) ProtoMessage ¶ added in v0.10.0 

func (*ListPluginsResponse) ProtoMessage()

func (*ListPluginsResponse) Reset ¶ added in v0.10.0 

func (m *ListPluginsResponse) Reset()

func (*ListPluginsResponse) String ¶ added in v0.10.0 

func (m *ListPluginsResponse) String() string

type ObjectStoreClient ¶ 

type ObjectStoreClient interface {
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*Empty, error)
	PutObject(ctx context.Context, opts ...grpc.CallOption) (ObjectStore_PutObjectClient, error)
	GetObject(ctx context.Context, in *GetObjectRequest, opts ...grpc.CallOption) (ObjectStore_GetObjectClient, error)
	ListCommonPrefixes(ctx context.Context, in *ListCommonPrefixesRequest, opts ...grpc.CallOption) (*ListCommonPrefixesResponse, error)
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (*ListObjectsResponse, error)
	DeleteObject(ctx context.Context, in *DeleteObjectRequest, opts ...grpc.CallOption) (*Empty, error)
	CreateSignedURL(ctx context.Context, in *CreateSignedURLRequest, opts ...grpc.CallOption) (*CreateSignedURLResponse, error)
}

func NewObjectStoreClient ¶ 

func NewObjectStoreClient(cc *grpc.ClientConn) ObjectStoreClient

type ObjectStoreServer ¶ 

type ObjectStoreServer interface {
	Init(context.Context, *InitRequest) (*Empty, error)
	PutObject(ObjectStore_PutObjectServer) error
	GetObject(*GetObjectRequest, ObjectStore_GetObjectServer) error
	ListCommonPrefixes(context.Context, *ListCommonPrefixesRequest) (*ListCommonPrefixesResponse, error)
	ListObjects(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)
	DeleteObject(context.Context, *DeleteObjectRequest) (*Empty, error)
	CreateSignedURL(context.Context, *CreateSignedURLRequest) (*CreateSignedURLResponse, error)
}

type ObjectStore_GetObjectClient ¶ 

type ObjectStore_GetObjectClient interface {
	Recv() (*Bytes, error)
	grpc.ClientStream
}

type ObjectStore_GetObjectServer ¶ 

type ObjectStore_GetObjectServer interface {
	Send(*Bytes) error
	grpc.ServerStream
}

type ObjectStore_PutObjectClient ¶ 

type ObjectStore_PutObjectClient interface {
	Send(*PutObjectRequest) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type ObjectStore_PutObjectServer ¶ 

type ObjectStore_PutObjectServer interface {
	SendAndClose(*Empty) error
	Recv() (*PutObjectRequest, error)
	grpc.ServerStream
}

type PluginIdentifier ¶ added in v0.10.0 

type PluginIdentifier struct {
	Command string `protobuf:"bytes,1,opt,name=command" json:"command,omitempty"`
	Kind    string `protobuf:"bytes,2,opt,name=kind" json:"kind,omitempty"`
	Name    string `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
}

func (*PluginIdentifier) Descriptor ¶ added in v0.10.0 

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

func (*PluginIdentifier) GetCommand ¶ added in v0.10.0 

func (m *PluginIdentifier) GetCommand() string

func (*PluginIdentifier) GetKind ¶ added in v0.10.0 

func (m *PluginIdentifier) GetKind() string

func (*PluginIdentifier) GetName ¶ added in v0.10.0 

func (m *PluginIdentifier) GetName() string

func (*PluginIdentifier) ProtoMessage ¶ added in v0.10.0 

func (*PluginIdentifier) ProtoMessage()

func (*PluginIdentifier) Reset ¶ added in v0.10.0 

func (m *PluginIdentifier) Reset()

func (*PluginIdentifier) String ¶ added in v0.10.0 

func (m *PluginIdentifier) String() string

type PluginListerClient ¶ added in v0.10.0 

type PluginListerClient interface {
	ListPlugins(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListPluginsResponse, error)
}

func NewPluginListerClient ¶ added in v0.10.0 

func NewPluginListerClient(cc *grpc.ClientConn) PluginListerClient

type PluginListerServer ¶ added in v0.10.0 

type PluginListerServer interface {
	ListPlugins(context.Context, *Empty) (*ListPluginsResponse, error)
}

type PutObjectRequest ¶ 

type PutObjectRequest struct {
	Plugin string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	Bucket string `protobuf:"bytes,2,opt,name=bucket" json:"bucket,omitempty"`
	Key    string `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"`
	Body   []byte `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
}

func (*PutObjectRequest) Descriptor ¶ 

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

func (*PutObjectRequest) GetBody ¶ 

func (m *PutObjectRequest) GetBody() []byte

func (*PutObjectRequest) GetBucket ¶ 

func (m *PutObjectRequest) GetBucket() string

func (*PutObjectRequest) GetKey ¶ 

func (m *PutObjectRequest) GetKey() string

func (*PutObjectRequest) GetPlugin ¶ added in v0.10.0 

func (m *PutObjectRequest) GetPlugin() string

func (*PutObjectRequest) ProtoMessage ¶ 

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) Reset ¶ 

func (m *PutObjectRequest) Reset()

func (*PutObjectRequest) String ¶ 

func (m *PutObjectRequest) String() string

type ResourceIdentifier ¶ 

type ResourceIdentifier struct {
	Group     string `protobuf:"bytes,1,opt,name=group" json:"group,omitempty"`
	Resource  string `protobuf:"bytes,2,opt,name=resource" json:"resource,omitempty"`
	Namespace string `protobuf:"bytes,3,opt,name=namespace" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"`
}

func (*ResourceIdentifier) Descriptor ¶ 

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

func (*ResourceIdentifier) GetGroup ¶ 

func (m *ResourceIdentifier) GetGroup() string

func (*ResourceIdentifier) GetName ¶ 

func (m *ResourceIdentifier) GetName() string

func (*ResourceIdentifier) GetNamespace ¶ 

func (m *ResourceIdentifier) GetNamespace() string

func (*ResourceIdentifier) GetResource ¶ 

func (m *ResourceIdentifier) GetResource() string

func (*ResourceIdentifier) ProtoMessage ¶ 

func (*ResourceIdentifier) ProtoMessage()

func (*ResourceIdentifier) Reset ¶ 

func (m *ResourceIdentifier) Reset()

func (*ResourceIdentifier) String ¶ 

func (m *ResourceIdentifier) String() string

type RestoreExecuteRequest ¶ 

type RestoreExecuteRequest struct {
	Plugin  string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	Item    []byte `protobuf:"bytes,2,opt,name=item,proto3" json:"item,omitempty"`
	Restore []byte `protobuf:"bytes,3,opt,name=restore,proto3" json:"restore,omitempty"`
}

func (*RestoreExecuteRequest) Descriptor ¶ 

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

func (*RestoreExecuteRequest) GetItem ¶ 

func (m *RestoreExecuteRequest) GetItem() []byte

func (*RestoreExecuteRequest) GetPlugin ¶ added in v0.10.0 

func (m *RestoreExecuteRequest) GetPlugin() string

func (*RestoreExecuteRequest) GetRestore ¶ 

func (m *RestoreExecuteRequest) GetRestore() []byte

func (*RestoreExecuteRequest) ProtoMessage ¶ 

func (*RestoreExecuteRequest) ProtoMessage()

func (*RestoreExecuteRequest) Reset ¶ 

func (m *RestoreExecuteRequest) Reset()

func (*RestoreExecuteRequest) String ¶ 

func (m *RestoreExecuteRequest) String() string

type RestoreExecuteResponse ¶ 

type RestoreExecuteResponse struct {
	Item    []byte `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	Warning string `protobuf:"bytes,2,opt,name=warning" json:"warning,omitempty"`
}

func (*RestoreExecuteResponse) Descriptor ¶ 

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

func (*RestoreExecuteResponse) GetItem ¶ 

func (m *RestoreExecuteResponse) GetItem() []byte

func (*RestoreExecuteResponse) GetWarning ¶ 

func (m *RestoreExecuteResponse) GetWarning() string

func (*RestoreExecuteResponse) ProtoMessage ¶ 

func (*RestoreExecuteResponse) ProtoMessage()

func (*RestoreExecuteResponse) Reset ¶ 

func (m *RestoreExecuteResponse) Reset()

func (*RestoreExecuteResponse) String ¶ 

func (m *RestoreExecuteResponse) String() string

type RestoreItemActionClient ¶ 

type RestoreItemActionClient interface {
	AppliesTo(ctx context.Context, in *AppliesToRequest, opts ...grpc.CallOption) (*AppliesToResponse, error)
	Execute(ctx context.Context, in *RestoreExecuteRequest, opts ...grpc.CallOption) (*RestoreExecuteResponse, error)
}

func NewRestoreItemActionClient ¶ 

func NewRestoreItemActionClient(cc *grpc.ClientConn) RestoreItemActionClient

type RestoreItemActionServer ¶ 

type RestoreItemActionServer interface {
	AppliesTo(context.Context, *AppliesToRequest) (*AppliesToResponse, error)
	Execute(context.Context, *RestoreExecuteRequest) (*RestoreExecuteResponse, error)
}

type SetVolumeIDRequest ¶ 

type SetVolumeIDRequest struct {
	Plugin           string `protobuf:"bytes,1,opt,name=plugin" json:"plugin,omitempty"`
	PersistentVolume []byte `protobuf:"bytes,2,opt,name=persistentVolume,proto3" json:"persistentVolume,omitempty"`
	VolumeID         string `protobuf:"bytes,3,opt,name=volumeID" json:"volumeID,omitempty"`
}

func (*SetVolumeIDRequest) Descriptor ¶ 

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

func (*SetVolumeIDRequest) GetPersistentVolume ¶ 

func (m *SetVolumeIDRequest) GetPersistentVolume() []byte

func (*SetVolumeIDRequest) GetPlugin ¶ added in v0.10.0 

func (m *SetVolumeIDRequest) GetPlugin() string

func (*SetVolumeIDRequest) GetVolumeID ¶ 

func (m *SetVolumeIDRequest) GetVolumeID() string

func (*SetVolumeIDRequest) ProtoMessage ¶ 

func (*SetVolumeIDRequest) ProtoMessage()

func (*SetVolumeIDRequest) Reset ¶ 

func (m *SetVolumeIDRequest) Reset()

func (*SetVolumeIDRequest) String ¶ 

func (m *SetVolumeIDRequest) String() string

type SetVolumeIDResponse ¶ 

type SetVolumeIDResponse struct {
	PersistentVolume []byte `protobuf:"bytes,1,opt,name=persistentVolume,proto3" json:"persistentVolume,omitempty"`
}

func (*SetVolumeIDResponse) Descriptor ¶ 

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

func (*SetVolumeIDResponse) GetPersistentVolume ¶ 

func (m *SetVolumeIDResponse) GetPersistentVolume() []byte

func (*SetVolumeIDResponse) ProtoMessage ¶ 

func (*SetVolumeIDResponse) ProtoMessage()

func (*SetVolumeIDResponse) Reset ¶ 

func (m *SetVolumeIDResponse) Reset()

func (*SetVolumeIDResponse) String ¶ 

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