Documentation ¶
Overview ¶
Package pb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func RegisterChorusHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterChorusHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChorusClient) error
- func RegisterChorusHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterChorusHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChorusServer) error
- func RegisterChorusServer(s grpc.ServiceRegistrar, srv ChorusServer)
- type AddReplicationRequest
- func (*AddReplicationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddReplicationRequest) GetAgentUrl() string
- func (x *AddReplicationRequest) GetBuckets() []string
- func (x *AddReplicationRequest) GetFrom() string
- func (x *AddReplicationRequest) GetIsForAllBuckets() bool
- func (x *AddReplicationRequest) GetTo() string
- func (x *AddReplicationRequest) GetUser() string
- func (*AddReplicationRequest) ProtoMessage()
- func (x *AddReplicationRequest) ProtoReflect() protoreflect.Message
- func (x *AddReplicationRequest) Reset()
- func (x *AddReplicationRequest) String() string
- type Agent
- type ChorusClient
- type ChorusServer
- type Chorus_StreamBucketReplicationClient
- type Chorus_StreamBucketReplicationServer
- type CompareBucketRequest
- func (*CompareBucketRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompareBucketRequest) GetBucket() string
- func (x *CompareBucketRequest) GetFrom() string
- func (x *CompareBucketRequest) GetShowMatch() bool
- func (x *CompareBucketRequest) GetTo() string
- func (x *CompareBucketRequest) GetUser() string
- func (*CompareBucketRequest) ProtoMessage()
- func (x *CompareBucketRequest) ProtoReflect() protoreflect.Message
- func (x *CompareBucketRequest) Reset()
- func (x *CompareBucketRequest) String() string
- type CompareBucketResponse
- func (*CompareBucketResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CompareBucketResponse) GetDiffer() []string
- func (x *CompareBucketResponse) GetError() []string
- func (x *CompareBucketResponse) GetIsMatch() bool
- func (x *CompareBucketResponse) GetMatch() []string
- func (x *CompareBucketResponse) GetMissFrom() []string
- func (x *CompareBucketResponse) GetMissTo() []string
- func (*CompareBucketResponse) ProtoMessage()
- func (x *CompareBucketResponse) ProtoReflect() protoreflect.Message
- func (x *CompareBucketResponse) Reset()
- func (x *CompareBucketResponse) String() string
- type Credential
- func (*Credential) Descriptor() ([]byte, []int)deprecated
- func (x *Credential) GetAccessKey() string
- func (x *Credential) GetAlias() string
- func (x *Credential) GetSecretKey() string
- func (*Credential) ProtoMessage()
- func (x *Credential) ProtoReflect() protoreflect.Message
- func (x *Credential) Reset()
- func (x *Credential) String() string
- type DeleteUserReplicationRequest
- func (*DeleteUserReplicationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteUserReplicationRequest) GetDeleteBucketReplications() bool
- func (x *DeleteUserReplicationRequest) GetFrom() string
- func (x *DeleteUserReplicationRequest) GetTo() string
- func (x *DeleteUserReplicationRequest) GetUser() string
- func (*DeleteUserReplicationRequest) ProtoMessage()
- func (x *DeleteUserReplicationRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteUserReplicationRequest) Reset()
- func (x *DeleteUserReplicationRequest) String() string
- type GetAgentsResponse
- type GetProxyCredentialsResponse
- func (*GetProxyCredentialsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetProxyCredentialsResponse) GetAddress() string
- func (x *GetProxyCredentialsResponse) GetCredentials() []*Credential
- func (*GetProxyCredentialsResponse) ProtoMessage()
- func (x *GetProxyCredentialsResponse) ProtoReflect() protoreflect.Message
- func (x *GetProxyCredentialsResponse) Reset()
- func (x *GetProxyCredentialsResponse) String() string
- type GetStoragesResponse
- func (*GetStoragesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStoragesResponse) GetStorages() []*Storage
- func (*GetStoragesResponse) ProtoMessage()
- func (x *GetStoragesResponse) ProtoReflect() protoreflect.Message
- func (x *GetStoragesResponse) Reset()
- func (x *GetStoragesResponse) String() string
- type ListBucketsForReplicationRequest
- func (*ListBucketsForReplicationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListBucketsForReplicationRequest) GetFrom() string
- func (x *ListBucketsForReplicationRequest) GetShowReplicated() bool
- func (x *ListBucketsForReplicationRequest) GetTo() string
- func (x *ListBucketsForReplicationRequest) GetUser() string
- func (*ListBucketsForReplicationRequest) ProtoMessage()
- func (x *ListBucketsForReplicationRequest) ProtoReflect() protoreflect.Message
- func (x *ListBucketsForReplicationRequest) Reset()
- func (x *ListBucketsForReplicationRequest) String() string
- type ListBucketsForReplicationResponse
- func (*ListBucketsForReplicationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListBucketsForReplicationResponse) GetBuckets() []string
- func (x *ListBucketsForReplicationResponse) GetReplicatedBuckets() []string
- func (*ListBucketsForReplicationResponse) ProtoMessage()
- func (x *ListBucketsForReplicationResponse) ProtoReflect() protoreflect.Message
- func (x *ListBucketsForReplicationResponse) Reset()
- func (x *ListBucketsForReplicationResponse) String() string
- type ListReplicationsResponse
- func (*ListReplicationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListReplicationsResponse) GetReplications() []*Replication
- func (*ListReplicationsResponse) ProtoMessage()
- func (x *ListReplicationsResponse) ProtoReflect() protoreflect.Message
- func (x *ListReplicationsResponse) Reset()
- func (x *ListReplicationsResponse) String() string
- type ListUserReplicationsResponse
- func (*ListUserReplicationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListUserReplicationsResponse) GetReplications() []*UserReplication
- func (*ListUserReplicationsResponse) ProtoMessage()
- func (x *ListUserReplicationsResponse) ProtoReflect() protoreflect.Message
- func (x *ListUserReplicationsResponse) Reset()
- func (x *ListUserReplicationsResponse) String() string
- type Replication
- func (*Replication) Descriptor() ([]byte, []int)deprecated
- func (x *Replication) GetAgentUrl() string
- func (x *Replication) GetBucket() string
- func (x *Replication) GetCreatedAt() *timestamppb.Timestamp
- func (x *Replication) GetEvents() int64
- func (x *Replication) GetEventsDone() int64
- func (x *Replication) GetFrom() string
- func (x *Replication) GetInitBytesDone() int64
- func (x *Replication) GetInitBytesListed() int64
- func (x *Replication) GetInitObjDone() int64
- func (x *Replication) GetInitObjListed() int64
- func (x *Replication) GetIsInitDone() bool
- func (x *Replication) GetIsPaused() bool
- func (x *Replication) GetLastEmittedAt() *timestamppb.Timestamp
- func (x *Replication) GetLastProcessedAt() *timestamppb.Timestamp
- func (x *Replication) GetSwitchStatus() Replication_SwitchEnum
- func (x *Replication) GetTo() string
- func (x *Replication) GetUser() string
- func (*Replication) ProtoMessage()
- func (x *Replication) ProtoReflect() protoreflect.Message
- func (x *Replication) Reset()
- func (x *Replication) String() string
- type ReplicationRequest
- func (*ReplicationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReplicationRequest) GetBucket() string
- func (x *ReplicationRequest) GetFrom() string
- func (x *ReplicationRequest) GetTo() string
- func (x *ReplicationRequest) GetUser() string
- func (*ReplicationRequest) ProtoMessage()
- func (x *ReplicationRequest) ProtoReflect() protoreflect.Message
- func (x *ReplicationRequest) Reset()
- func (x *ReplicationRequest) String() string
- type Replication_SwitchEnum
- func (Replication_SwitchEnum) Descriptor() protoreflect.EnumDescriptor
- func (x Replication_SwitchEnum) Enum() *Replication_SwitchEnum
- func (Replication_SwitchEnum) EnumDescriptor() ([]byte, []int)deprecated
- func (x Replication_SwitchEnum) Number() protoreflect.EnumNumber
- func (x Replication_SwitchEnum) String() string
- func (Replication_SwitchEnum) Type() protoreflect.EnumType
- type Storage
- func (*Storage) Descriptor() ([]byte, []int)deprecated
- func (x *Storage) GetAddress() string
- func (x *Storage) GetCredentials() []*Credential
- func (x *Storage) GetIsMain() bool
- func (x *Storage) GetName() string
- func (x *Storage) GetProvider() Storage_Provider
- func (*Storage) ProtoMessage()
- func (x *Storage) ProtoReflect() protoreflect.Message
- func (x *Storage) Reset()
- func (x *Storage) String() string
- type Storage_Provider
- func (Storage_Provider) Descriptor() protoreflect.EnumDescriptor
- func (x Storage_Provider) Enum() *Storage_Provider
- func (Storage_Provider) EnumDescriptor() ([]byte, []int)deprecated
- func (x Storage_Provider) Number() protoreflect.EnumNumber
- func (x Storage_Provider) String() string
- func (Storage_Provider) Type() protoreflect.EnumType
- type SwitchMainBucketRequest
- func (*SwitchMainBucketRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SwitchMainBucketRequest) GetBucket() string
- func (x *SwitchMainBucketRequest) GetNewMain() string
- func (x *SwitchMainBucketRequest) GetUser() string
- func (*SwitchMainBucketRequest) ProtoMessage()
- func (x *SwitchMainBucketRequest) ProtoReflect() protoreflect.Message
- func (x *SwitchMainBucketRequest) Reset()
- func (x *SwitchMainBucketRequest) String() string
- type UnimplementedChorusServer
- func (UnimplementedChorusServer) AddReplication(context.Context, *AddReplicationRequest) (*emptypb.Empty, error)
- func (UnimplementedChorusServer) CompareBucket(context.Context, *CompareBucketRequest) (*CompareBucketResponse, error)
- func (UnimplementedChorusServer) DeleteReplication(context.Context, *ReplicationRequest) (*emptypb.Empty, error)
- func (UnimplementedChorusServer) DeleteUserReplication(context.Context, *DeleteUserReplicationRequest) (*emptypb.Empty, error)
- func (UnimplementedChorusServer) GetAgents(context.Context, *emptypb.Empty) (*GetAgentsResponse, error)
- func (UnimplementedChorusServer) GetProxyCredentials(context.Context, *emptypb.Empty) (*GetProxyCredentialsResponse, error)
- func (UnimplementedChorusServer) GetStorages(context.Context, *emptypb.Empty) (*GetStoragesResponse, error)
- func (UnimplementedChorusServer) ListBucketsForReplication(context.Context, *ListBucketsForReplicationRequest) (*ListBucketsForReplicationResponse, error)
- func (UnimplementedChorusServer) ListReplications(context.Context, *emptypb.Empty) (*ListReplicationsResponse, error)
- func (UnimplementedChorusServer) ListUserReplications(context.Context, *emptypb.Empty) (*ListUserReplicationsResponse, error)
- func (UnimplementedChorusServer) PauseReplication(context.Context, *ReplicationRequest) (*emptypb.Empty, error)
- func (UnimplementedChorusServer) ResumeReplication(context.Context, *ReplicationRequest) (*emptypb.Empty, error)
- func (UnimplementedChorusServer) StreamBucketReplication(*ReplicationRequest, Chorus_StreamBucketReplicationServer) error
- func (UnimplementedChorusServer) SwitchMainBucket(context.Context, *SwitchMainBucketRequest) (*emptypb.Empty, error)
- type UnsafeChorusServer
- type UserReplication
- func (*UserReplication) Descriptor() ([]byte, []int)deprecated
- func (x *UserReplication) GetFrom() string
- func (x *UserReplication) GetTo() string
- func (x *UserReplication) GetUser() string
- func (*UserReplication) ProtoMessage()
- func (x *UserReplication) ProtoReflect() protoreflect.Message
- func (x *UserReplication) Reset()
- func (x *UserReplication) String() string
Constants ¶
const ( Chorus_GetStorages_FullMethodName = "/chorus.Chorus/GetStorages" Chorus_GetProxyCredentials_FullMethodName = "/chorus.Chorus/GetProxyCredentials" Chorus_ListBucketsForReplication_FullMethodName = "/chorus.Chorus/ListBucketsForReplication" Chorus_AddReplication_FullMethodName = "/chorus.Chorus/AddReplication" Chorus_ListReplications_FullMethodName = "/chorus.Chorus/ListReplications" Chorus_ListUserReplications_FullMethodName = "/chorus.Chorus/ListUserReplications" Chorus_StreamBucketReplication_FullMethodName = "/chorus.Chorus/StreamBucketReplication" Chorus_PauseReplication_FullMethodName = "/chorus.Chorus/PauseReplication" Chorus_ResumeReplication_FullMethodName = "/chorus.Chorus/ResumeReplication" Chorus_DeleteReplication_FullMethodName = "/chorus.Chorus/DeleteReplication" Chorus_DeleteUserReplication_FullMethodName = "/chorus.Chorus/DeleteUserReplication" Chorus_SwitchMainBucket_FullMethodName = "/chorus.Chorus/SwitchMainBucket" Chorus_CompareBucket_FullMethodName = "/chorus.Chorus/CompareBucket" Chorus_GetAgents_FullMethodName = "/chorus.Chorus/GetAgents" )
Variables ¶
var ( Storage_Provider_name = map[int32]string{ 0: "Other", 1: "Ceph", 2: "Minio", 3: "AWS", 4: "GCS", 5: "Alibaba", 6: "Cloudflare", 7: "DigitalOcean", } Storage_Provider_value = map[string]int32{ "Other": 0, "Ceph": 1, "Minio": 2, "AWS": 3, "GCS": 4, "Alibaba": 5, "Cloudflare": 6, "DigitalOcean": 7, } )
Enum value maps for Storage_Provider.
var ( Replication_SwitchEnum_name = map[int32]string{ 0: "NotStarted", 1: "InProgress", 2: "Done", } Replication_SwitchEnum_value = map[string]int32{ "NotStarted": 0, "InProgress": 1, "Done": 2, } )
Enum value maps for Replication_SwitchEnum.
var Chorus_ServiceDesc = grpc.ServiceDesc{ ServiceName: "chorus.Chorus", HandlerType: (*ChorusServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetStorages", Handler: _Chorus_GetStorages_Handler, }, { MethodName: "GetProxyCredentials", Handler: _Chorus_GetProxyCredentials_Handler, }, { MethodName: "ListBucketsForReplication", Handler: _Chorus_ListBucketsForReplication_Handler, }, { MethodName: "AddReplication", Handler: _Chorus_AddReplication_Handler, }, { MethodName: "ListReplications", Handler: _Chorus_ListReplications_Handler, }, { MethodName: "ListUserReplications", Handler: _Chorus_ListUserReplications_Handler, }, { MethodName: "PauseReplication", Handler: _Chorus_PauseReplication_Handler, }, { MethodName: "ResumeReplication", Handler: _Chorus_ResumeReplication_Handler, }, { MethodName: "DeleteReplication", Handler: _Chorus_DeleteReplication_Handler, }, { MethodName: "DeleteUserReplication", Handler: _Chorus_DeleteUserReplication_Handler, }, { MethodName: "SwitchMainBucket", Handler: _Chorus_SwitchMainBucket_Handler, }, { MethodName: "CompareBucket", Handler: _Chorus_CompareBucket_Handler, }, { MethodName: "GetAgents", Handler: _Chorus_GetAgents_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamBucketReplication", Handler: _Chorus_StreamBucketReplication_Handler, ServerStreams: true, }, }, Metadata: "chorus/chorus.proto", }
Chorus_ServiceDesc is the grpc.ServiceDesc for Chorus service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_chorus_chorus_proto protoreflect.FileDescriptor
Functions ¶
func RegisterChorusHandler ¶
RegisterChorusHandler registers the http handlers for service Chorus to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterChorusHandlerClient ¶
func RegisterChorusHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChorusClient) error
RegisterChorusHandlerClient registers the http handlers for service Chorus to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ChorusClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ChorusClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ChorusClient" to call the correct interceptors.
func RegisterChorusHandlerFromEndpoint ¶
func RegisterChorusHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterChorusHandlerFromEndpoint is same as RegisterChorusHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterChorusHandlerServer ¶
func RegisterChorusHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChorusServer) error
RegisterChorusHandlerServer registers the http handlers for service Chorus to "mux". UnaryRPC :call ChorusServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterChorusHandlerFromEndpoint instead.
func RegisterChorusServer ¶
func RegisterChorusServer(s grpc.ServiceRegistrar, srv ChorusServer)
Types ¶
type AddReplicationRequest ¶
type AddReplicationRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` From string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"` To string `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"` Buckets []string `protobuf:"bytes,5,rep,name=buckets,proto3" json:"buckets,omitempty"` IsForAllBuckets bool `protobuf:"varint,6,opt,name=is_for_all_buckets,json=isForAllBuckets,proto3" json:"is_for_all_buckets,omitempty"` AgentUrl *string `protobuf:"bytes,7,opt,name=agent_url,json=agentUrl,proto3,oneof" json:"agent_url,omitempty"` // contains filtered or unexported fields }
func (*AddReplicationRequest) Descriptor
deprecated
func (*AddReplicationRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddReplicationRequest.ProtoReflect.Descriptor instead.
func (*AddReplicationRequest) GetAgentUrl ¶
func (x *AddReplicationRequest) GetAgentUrl() string
func (*AddReplicationRequest) GetBuckets ¶
func (x *AddReplicationRequest) GetBuckets() []string
func (*AddReplicationRequest) GetFrom ¶
func (x *AddReplicationRequest) GetFrom() string
func (*AddReplicationRequest) GetIsForAllBuckets ¶
func (x *AddReplicationRequest) GetIsForAllBuckets() bool
func (*AddReplicationRequest) GetTo ¶
func (x *AddReplicationRequest) GetTo() string
func (*AddReplicationRequest) GetUser ¶
func (x *AddReplicationRequest) GetUser() string
func (*AddReplicationRequest) ProtoMessage ¶
func (*AddReplicationRequest) ProtoMessage()
func (*AddReplicationRequest) ProtoReflect ¶
func (x *AddReplicationRequest) ProtoReflect() protoreflect.Message
func (*AddReplicationRequest) Reset ¶
func (x *AddReplicationRequest) Reset()
func (*AddReplicationRequest) String ¶
func (x *AddReplicationRequest) String() string
type Agent ¶
type Agent struct { Storage string `protobuf:"bytes,1,opt,name=storage,proto3" json:"storage,omitempty"` Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"` // contains filtered or unexported fields }
func (*Agent) Descriptor
deprecated
func (*Agent) GetStorage ¶
func (*Agent) ProtoMessage ¶
func (*Agent) ProtoMessage()
func (*Agent) ProtoReflect ¶
func (x *Agent) ProtoReflect() protoreflect.Message
type ChorusClient ¶
type ChorusClient interface { // Lists configured storages with users GetStorages(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetStoragesResponse, error) // Returns connection details for proxy s3 endpoint GetProxyCredentials(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetProxyCredentialsResponse, error) // Returns list of buckets to configure new replication. ListBucketsForReplication(ctx context.Context, in *ListBucketsForReplicationRequest, opts ...grpc.CallOption) (*ListBucketsForReplicationResponse, error) // Configures new replication for user or bucket(-s) AddReplication(ctx context.Context, in *AddReplicationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Lists configured replications with statuses ListReplications(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListReplicationsResponse, error) ListUserReplications(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListUserReplicationsResponse, error) StreamBucketReplication(ctx context.Context, in *ReplicationRequest, opts ...grpc.CallOption) (Chorus_StreamBucketReplicationClient, error) // Pauses given replication PauseReplication(ctx context.Context, in *ReplicationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Resumes given replication ResumeReplication(ctx context.Context, in *ReplicationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Deletes given replication DeleteReplication(ctx context.Context, in *ReplicationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) DeleteUserReplication(ctx context.Context, in *DeleteUserReplicationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) SwitchMainBucket(ctx context.Context, in *SwitchMainBucketRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Compares contents of given bucket in given storages CompareBucket(ctx context.Context, in *CompareBucketRequest, opts ...grpc.CallOption) (*CompareBucketResponse, error) GetAgents(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetAgentsResponse, error) }
ChorusClient is the client API for Chorus service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewChorusClient ¶
func NewChorusClient(cc grpc.ClientConnInterface) ChorusClient
type ChorusServer ¶
type ChorusServer interface { // Lists configured storages with users GetStorages(context.Context, *emptypb.Empty) (*GetStoragesResponse, error) // Returns connection details for proxy s3 endpoint GetProxyCredentials(context.Context, *emptypb.Empty) (*GetProxyCredentialsResponse, error) // Returns list of buckets to configure new replication. ListBucketsForReplication(context.Context, *ListBucketsForReplicationRequest) (*ListBucketsForReplicationResponse, error) // Configures new replication for user or bucket(-s) AddReplication(context.Context, *AddReplicationRequest) (*emptypb.Empty, error) // Lists configured replications with statuses ListReplications(context.Context, *emptypb.Empty) (*ListReplicationsResponse, error) ListUserReplications(context.Context, *emptypb.Empty) (*ListUserReplicationsResponse, error) StreamBucketReplication(*ReplicationRequest, Chorus_StreamBucketReplicationServer) error // Pauses given replication PauseReplication(context.Context, *ReplicationRequest) (*emptypb.Empty, error) // Resumes given replication ResumeReplication(context.Context, *ReplicationRequest) (*emptypb.Empty, error) // Deletes given replication DeleteReplication(context.Context, *ReplicationRequest) (*emptypb.Empty, error) DeleteUserReplication(context.Context, *DeleteUserReplicationRequest) (*emptypb.Empty, error) SwitchMainBucket(context.Context, *SwitchMainBucketRequest) (*emptypb.Empty, error) // Compares contents of given bucket in given storages CompareBucket(context.Context, *CompareBucketRequest) (*CompareBucketResponse, error) GetAgents(context.Context, *emptypb.Empty) (*GetAgentsResponse, error) }
ChorusServer is the server API for Chorus service. All implementations should embed UnimplementedChorusServer for forward compatibility
type Chorus_StreamBucketReplicationClient ¶
type Chorus_StreamBucketReplicationClient interface { Recv() (*Replication, error) grpc.ClientStream }
type Chorus_StreamBucketReplicationServer ¶
type Chorus_StreamBucketReplicationServer interface { Send(*Replication) error grpc.ServerStream }
type CompareBucketRequest ¶
type CompareBucketRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Bucket string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"` From string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"` To string `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"` // set true to get list of matching files (match) in response ShowMatch bool `protobuf:"varint,5,opt,name=show_match,json=showMatch,proto3" json:"show_match,omitempty"` // contains filtered or unexported fields }
func (*CompareBucketRequest) Descriptor
deprecated
func (*CompareBucketRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompareBucketRequest.ProtoReflect.Descriptor instead.
func (*CompareBucketRequest) GetBucket ¶
func (x *CompareBucketRequest) GetBucket() string
func (*CompareBucketRequest) GetFrom ¶
func (x *CompareBucketRequest) GetFrom() string
func (*CompareBucketRequest) GetShowMatch ¶
func (x *CompareBucketRequest) GetShowMatch() bool
func (*CompareBucketRequest) GetTo ¶
func (x *CompareBucketRequest) GetTo() string
func (*CompareBucketRequest) GetUser ¶
func (x *CompareBucketRequest) GetUser() string
func (*CompareBucketRequest) ProtoMessage ¶
func (*CompareBucketRequest) ProtoMessage()
func (*CompareBucketRequest) ProtoReflect ¶
func (x *CompareBucketRequest) ProtoReflect() protoreflect.Message
func (*CompareBucketRequest) Reset ¶
func (x *CompareBucketRequest) Reset()
func (*CompareBucketRequest) String ¶
func (x *CompareBucketRequest) String() string
type CompareBucketResponse ¶
type CompareBucketResponse struct { // true if storage's buckets have the same content IsMatch bool `protobuf:"varint,1,opt,name=is_match,json=isMatch,proto3" json:"is_match,omitempty"` // list of missing files in 'from storage' bucket MissFrom []string `protobuf:"bytes,2,rep,name=miss_from,json=missFrom,proto3" json:"miss_from,omitempty"` // list of missing files in 'to storage' bucket MissTo []string `protobuf:"bytes,3,rep,name=miss_to,json=missTo,proto3" json:"miss_to,omitempty"` // list of files with different content Differ []string `protobuf:"bytes,4,rep,name=differ,proto3" json:"differ,omitempty"` // list of errors occurred during comparison Error []string `protobuf:"bytes,5,rep,name=error,proto3" json:"error,omitempty"` // list matched files in storages bucket. // will be empty if request parameter show_match set to false. Match []string `protobuf:"bytes,6,rep,name=match,proto3" json:"match,omitempty"` // contains filtered or unexported fields }
func (*CompareBucketResponse) Descriptor
deprecated
func (*CompareBucketResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompareBucketResponse.ProtoReflect.Descriptor instead.
func (*CompareBucketResponse) GetDiffer ¶
func (x *CompareBucketResponse) GetDiffer() []string
func (*CompareBucketResponse) GetError ¶
func (x *CompareBucketResponse) GetError() []string
func (*CompareBucketResponse) GetIsMatch ¶
func (x *CompareBucketResponse) GetIsMatch() bool
func (*CompareBucketResponse) GetMatch ¶
func (x *CompareBucketResponse) GetMatch() []string
func (*CompareBucketResponse) GetMissFrom ¶
func (x *CompareBucketResponse) GetMissFrom() []string
func (*CompareBucketResponse) GetMissTo ¶
func (x *CompareBucketResponse) GetMissTo() []string
func (*CompareBucketResponse) ProtoMessage ¶
func (*CompareBucketResponse) ProtoMessage()
func (*CompareBucketResponse) ProtoReflect ¶
func (x *CompareBucketResponse) ProtoReflect() protoreflect.Message
func (*CompareBucketResponse) Reset ¶
func (x *CompareBucketResponse) Reset()
func (*CompareBucketResponse) String ¶
func (x *CompareBucketResponse) String() string
type Credential ¶
type Credential struct { Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"` AccessKey string `protobuf:"bytes,2,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"` SecretKey string `protobuf:"bytes,3,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"` // contains filtered or unexported fields }
func (*Credential) Descriptor
deprecated
func (*Credential) Descriptor() ([]byte, []int)
Deprecated: Use Credential.ProtoReflect.Descriptor instead.
func (*Credential) GetAccessKey ¶
func (x *Credential) GetAccessKey() string
func (*Credential) GetAlias ¶
func (x *Credential) GetAlias() string
func (*Credential) GetSecretKey ¶
func (x *Credential) GetSecretKey() string
func (*Credential) ProtoMessage ¶
func (*Credential) ProtoMessage()
func (*Credential) ProtoReflect ¶
func (x *Credential) ProtoReflect() protoreflect.Message
func (*Credential) Reset ¶
func (x *Credential) Reset()
func (*Credential) String ¶
func (x *Credential) String() string
type DeleteUserReplicationRequest ¶
type DeleteUserReplicationRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` To string `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"` DeleteBucketReplications bool `` /* 136-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DeleteUserReplicationRequest) Descriptor
deprecated
func (*DeleteUserReplicationRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteUserReplicationRequest.ProtoReflect.Descriptor instead.
func (*DeleteUserReplicationRequest) GetDeleteBucketReplications ¶
func (x *DeleteUserReplicationRequest) GetDeleteBucketReplications() bool
func (*DeleteUserReplicationRequest) GetFrom ¶
func (x *DeleteUserReplicationRequest) GetFrom() string
func (*DeleteUserReplicationRequest) GetTo ¶
func (x *DeleteUserReplicationRequest) GetTo() string
func (*DeleteUserReplicationRequest) GetUser ¶
func (x *DeleteUserReplicationRequest) GetUser() string
func (*DeleteUserReplicationRequest) ProtoMessage ¶
func (*DeleteUserReplicationRequest) ProtoMessage()
func (*DeleteUserReplicationRequest) ProtoReflect ¶
func (x *DeleteUserReplicationRequest) ProtoReflect() protoreflect.Message
func (*DeleteUserReplicationRequest) Reset ¶
func (x *DeleteUserReplicationRequest) Reset()
func (*DeleteUserReplicationRequest) String ¶
func (x *DeleteUserReplicationRequest) String() string
type GetAgentsResponse ¶
type GetAgentsResponse struct { Agents []*Agent `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"` // contains filtered or unexported fields }
func (*GetAgentsResponse) Descriptor
deprecated
func (*GetAgentsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetAgentsResponse.ProtoReflect.Descriptor instead.
func (*GetAgentsResponse) GetAgents ¶
func (x *GetAgentsResponse) GetAgents() []*Agent
func (*GetAgentsResponse) ProtoMessage ¶
func (*GetAgentsResponse) ProtoMessage()
func (*GetAgentsResponse) ProtoReflect ¶
func (x *GetAgentsResponse) ProtoReflect() protoreflect.Message
func (*GetAgentsResponse) Reset ¶
func (x *GetAgentsResponse) Reset()
func (*GetAgentsResponse) String ¶
func (x *GetAgentsResponse) String() string
type GetProxyCredentialsResponse ¶
type GetProxyCredentialsResponse struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Credentials []*Credential `protobuf:"bytes,2,rep,name=credentials,proto3" json:"credentials,omitempty"` // contains filtered or unexported fields }
func (*GetProxyCredentialsResponse) Descriptor
deprecated
func (*GetProxyCredentialsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetProxyCredentialsResponse.ProtoReflect.Descriptor instead.
func (*GetProxyCredentialsResponse) GetAddress ¶
func (x *GetProxyCredentialsResponse) GetAddress() string
func (*GetProxyCredentialsResponse) GetCredentials ¶
func (x *GetProxyCredentialsResponse) GetCredentials() []*Credential
func (*GetProxyCredentialsResponse) ProtoMessage ¶
func (*GetProxyCredentialsResponse) ProtoMessage()
func (*GetProxyCredentialsResponse) ProtoReflect ¶
func (x *GetProxyCredentialsResponse) ProtoReflect() protoreflect.Message
func (*GetProxyCredentialsResponse) Reset ¶
func (x *GetProxyCredentialsResponse) Reset()
func (*GetProxyCredentialsResponse) String ¶
func (x *GetProxyCredentialsResponse) String() string
type GetStoragesResponse ¶
type GetStoragesResponse struct { Storages []*Storage `protobuf:"bytes,1,rep,name=storages,proto3" json:"storages,omitempty"` // contains filtered or unexported fields }
func (*GetStoragesResponse) Descriptor
deprecated
func (*GetStoragesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStoragesResponse.ProtoReflect.Descriptor instead.
func (*GetStoragesResponse) GetStorages ¶
func (x *GetStoragesResponse) GetStorages() []*Storage
func (*GetStoragesResponse) ProtoMessage ¶
func (*GetStoragesResponse) ProtoMessage()
func (*GetStoragesResponse) ProtoReflect ¶
func (x *GetStoragesResponse) ProtoReflect() protoreflect.Message
func (*GetStoragesResponse) Reset ¶
func (x *GetStoragesResponse) Reset()
func (*GetStoragesResponse) String ¶
func (x *GetStoragesResponse) String() string
type ListBucketsForReplicationRequest ¶
type ListBucketsForReplicationRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` To string `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"` ShowReplicated bool `protobuf:"varint,4,opt,name=show_replicated,json=showReplicated,proto3" json:"show_replicated,omitempty"` // contains filtered or unexported fields }
func (*ListBucketsForReplicationRequest) Descriptor
deprecated
func (*ListBucketsForReplicationRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListBucketsForReplicationRequest.ProtoReflect.Descriptor instead.
func (*ListBucketsForReplicationRequest) GetFrom ¶
func (x *ListBucketsForReplicationRequest) GetFrom() string
func (*ListBucketsForReplicationRequest) GetShowReplicated ¶
func (x *ListBucketsForReplicationRequest) GetShowReplicated() bool
func (*ListBucketsForReplicationRequest) GetTo ¶
func (x *ListBucketsForReplicationRequest) GetTo() string
func (*ListBucketsForReplicationRequest) GetUser ¶
func (x *ListBucketsForReplicationRequest) GetUser() string
func (*ListBucketsForReplicationRequest) ProtoMessage ¶
func (*ListBucketsForReplicationRequest) ProtoMessage()
func (*ListBucketsForReplicationRequest) ProtoReflect ¶
func (x *ListBucketsForReplicationRequest) ProtoReflect() protoreflect.Message
func (*ListBucketsForReplicationRequest) Reset ¶
func (x *ListBucketsForReplicationRequest) Reset()
func (*ListBucketsForReplicationRequest) String ¶
func (x *ListBucketsForReplicationRequest) String() string
type ListBucketsForReplicationResponse ¶
type ListBucketsForReplicationResponse struct { Buckets []string `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"` ReplicatedBuckets []string `protobuf:"bytes,2,rep,name=replicated_buckets,json=replicatedBuckets,proto3" json:"replicated_buckets,omitempty"` // contains filtered or unexported fields }
func (*ListBucketsForReplicationResponse) Descriptor
deprecated
func (*ListBucketsForReplicationResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListBucketsForReplicationResponse.ProtoReflect.Descriptor instead.
func (*ListBucketsForReplicationResponse) GetBuckets ¶
func (x *ListBucketsForReplicationResponse) GetBuckets() []string
func (*ListBucketsForReplicationResponse) GetReplicatedBuckets ¶
func (x *ListBucketsForReplicationResponse) GetReplicatedBuckets() []string
func (*ListBucketsForReplicationResponse) ProtoMessage ¶
func (*ListBucketsForReplicationResponse) ProtoMessage()
func (*ListBucketsForReplicationResponse) ProtoReflect ¶
func (x *ListBucketsForReplicationResponse) ProtoReflect() protoreflect.Message
func (*ListBucketsForReplicationResponse) Reset ¶
func (x *ListBucketsForReplicationResponse) Reset()
func (*ListBucketsForReplicationResponse) String ¶
func (x *ListBucketsForReplicationResponse) String() string
type ListReplicationsResponse ¶
type ListReplicationsResponse struct { Replications []*Replication `protobuf:"bytes,1,rep,name=replications,proto3" json:"replications,omitempty"` // contains filtered or unexported fields }
func (*ListReplicationsResponse) Descriptor
deprecated
func (*ListReplicationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListReplicationsResponse.ProtoReflect.Descriptor instead.
func (*ListReplicationsResponse) GetReplications ¶
func (x *ListReplicationsResponse) GetReplications() []*Replication
func (*ListReplicationsResponse) ProtoMessage ¶
func (*ListReplicationsResponse) ProtoMessage()
func (*ListReplicationsResponse) ProtoReflect ¶
func (x *ListReplicationsResponse) ProtoReflect() protoreflect.Message
func (*ListReplicationsResponse) Reset ¶
func (x *ListReplicationsResponse) Reset()
func (*ListReplicationsResponse) String ¶
func (x *ListReplicationsResponse) String() string
type ListUserReplicationsResponse ¶
type ListUserReplicationsResponse struct { Replications []*UserReplication `protobuf:"bytes,1,rep,name=replications,proto3" json:"replications,omitempty"` // contains filtered or unexported fields }
func (*ListUserReplicationsResponse) Descriptor
deprecated
func (*ListUserReplicationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListUserReplicationsResponse.ProtoReflect.Descriptor instead.
func (*ListUserReplicationsResponse) GetReplications ¶
func (x *ListUserReplicationsResponse) GetReplications() []*UserReplication
func (*ListUserReplicationsResponse) ProtoMessage ¶
func (*ListUserReplicationsResponse) ProtoMessage()
func (*ListUserReplicationsResponse) ProtoReflect ¶
func (x *ListUserReplicationsResponse) ProtoReflect() protoreflect.Message
func (*ListUserReplicationsResponse) Reset ¶
func (x *ListUserReplicationsResponse) Reset()
func (*ListUserReplicationsResponse) String ¶
func (x *ListUserReplicationsResponse) String() string
type Replication ¶
type Replication struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Bucket string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"` From string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"` To string `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` IsPaused bool `protobuf:"varint,6,opt,name=is_paused,json=isPaused,proto3" json:"is_paused,omitempty"` IsInitDone bool `protobuf:"varint,7,opt,name=is_init_done,json=isInitDone,proto3" json:"is_init_done,omitempty"` InitObjListed int64 `protobuf:"varint,8,opt,name=init_obj_listed,json=initObjListed,proto3" json:"init_obj_listed,omitempty"` InitObjDone int64 `protobuf:"varint,9,opt,name=init_obj_done,json=initObjDone,proto3" json:"init_obj_done,omitempty"` InitBytesListed int64 `protobuf:"varint,10,opt,name=init_bytes_listed,json=initBytesListed,proto3" json:"init_bytes_listed,omitempty"` InitBytesDone int64 `protobuf:"varint,11,opt,name=init_bytes_done,json=initBytesDone,proto3" json:"init_bytes_done,omitempty"` Events int64 `protobuf:"varint,12,opt,name=events,proto3" json:"events,omitempty"` EventsDone int64 `protobuf:"varint,13,opt,name=events_done,json=eventsDone,proto3" json:"events_done,omitempty"` LastEmittedAt *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=last_emitted_at,json=lastEmittedAt,proto3" json:"last_emitted_at,omitempty"` LastProcessedAt *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=last_processed_at,json=lastProcessedAt,proto3" json:"last_processed_at,omitempty"` AgentUrl *string `protobuf:"bytes,16,opt,name=agent_url,json=agentUrl,proto3,oneof" json:"agent_url,omitempty"` SwitchStatus Replication_SwitchEnum `` /* 134-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Replication) Descriptor
deprecated
func (*Replication) Descriptor() ([]byte, []int)
Deprecated: Use Replication.ProtoReflect.Descriptor instead.
func (*Replication) GetAgentUrl ¶
func (x *Replication) GetAgentUrl() string
func (*Replication) GetBucket ¶
func (x *Replication) GetBucket() string
func (*Replication) GetCreatedAt ¶
func (x *Replication) GetCreatedAt() *timestamppb.Timestamp
func (*Replication) GetEvents ¶
func (x *Replication) GetEvents() int64
func (*Replication) GetEventsDone ¶
func (x *Replication) GetEventsDone() int64
func (*Replication) GetFrom ¶
func (x *Replication) GetFrom() string
func (*Replication) GetInitBytesDone ¶
func (x *Replication) GetInitBytesDone() int64
func (*Replication) GetInitBytesListed ¶
func (x *Replication) GetInitBytesListed() int64
func (*Replication) GetInitObjDone ¶
func (x *Replication) GetInitObjDone() int64
func (*Replication) GetInitObjListed ¶
func (x *Replication) GetInitObjListed() int64
func (*Replication) GetIsInitDone ¶
func (x *Replication) GetIsInitDone() bool
func (*Replication) GetIsPaused ¶
func (x *Replication) GetIsPaused() bool
func (*Replication) GetLastEmittedAt ¶
func (x *Replication) GetLastEmittedAt() *timestamppb.Timestamp
func (*Replication) GetLastProcessedAt ¶
func (x *Replication) GetLastProcessedAt() *timestamppb.Timestamp
func (*Replication) GetSwitchStatus ¶ added in v0.5.2
func (x *Replication) GetSwitchStatus() Replication_SwitchEnum
func (*Replication) GetTo ¶
func (x *Replication) GetTo() string
func (*Replication) GetUser ¶
func (x *Replication) GetUser() string
func (*Replication) ProtoMessage ¶
func (*Replication) ProtoMessage()
func (*Replication) ProtoReflect ¶
func (x *Replication) ProtoReflect() protoreflect.Message
func (*Replication) Reset ¶
func (x *Replication) Reset()
func (*Replication) String ¶
func (x *Replication) String() string
type ReplicationRequest ¶
type ReplicationRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Bucket string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"` From string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"` To string `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"` // contains filtered or unexported fields }
func (*ReplicationRequest) Descriptor
deprecated
func (*ReplicationRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReplicationRequest.ProtoReflect.Descriptor instead.
func (*ReplicationRequest) GetBucket ¶
func (x *ReplicationRequest) GetBucket() string
func (*ReplicationRequest) GetFrom ¶
func (x *ReplicationRequest) GetFrom() string
func (*ReplicationRequest) GetTo ¶
func (x *ReplicationRequest) GetTo() string
func (*ReplicationRequest) GetUser ¶
func (x *ReplicationRequest) GetUser() string
func (*ReplicationRequest) ProtoMessage ¶
func (*ReplicationRequest) ProtoMessage()
func (*ReplicationRequest) ProtoReflect ¶
func (x *ReplicationRequest) ProtoReflect() protoreflect.Message
func (*ReplicationRequest) Reset ¶
func (x *ReplicationRequest) Reset()
func (*ReplicationRequest) String ¶
func (x *ReplicationRequest) String() string
type Replication_SwitchEnum ¶ added in v0.5.2
type Replication_SwitchEnum int32
const ( Replication_NotStarted Replication_SwitchEnum = 0 Replication_InProgress Replication_SwitchEnum = 1 Replication_Done Replication_SwitchEnum = 2 )
func (Replication_SwitchEnum) Descriptor ¶ added in v0.5.2
func (Replication_SwitchEnum) Descriptor() protoreflect.EnumDescriptor
func (Replication_SwitchEnum) Enum ¶ added in v0.5.2
func (x Replication_SwitchEnum) Enum() *Replication_SwitchEnum
func (Replication_SwitchEnum) EnumDescriptor
deprecated
added in
v0.5.2
func (Replication_SwitchEnum) EnumDescriptor() ([]byte, []int)
Deprecated: Use Replication_SwitchEnum.Descriptor instead.
func (Replication_SwitchEnum) Number ¶ added in v0.5.2
func (x Replication_SwitchEnum) Number() protoreflect.EnumNumber
func (Replication_SwitchEnum) String ¶ added in v0.5.2
func (x Replication_SwitchEnum) String() string
func (Replication_SwitchEnum) Type ¶ added in v0.5.2
func (Replication_SwitchEnum) Type() protoreflect.EnumType
type Storage ¶
type Storage struct { // some human-readable alias for storage config Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` IsMain bool `protobuf:"varint,2,opt,name=is_main,json=isMain,proto3" json:"is_main,omitempty"` // ex: s3.clyso.com Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` // s3 storage provider <Ceph|Minio|AWS|Other> Provider Storage_Provider `protobuf:"varint,4,opt,name=provider,proto3,enum=chorus.Storage_Provider" json:"provider,omitempty"` // credentials: access key (public, aka username) Credentials []*Credential `protobuf:"bytes,5,rep,name=credentials,proto3" json:"credentials,omitempty"` // contains filtered or unexported fields }
func (*Storage) Descriptor
deprecated
func (*Storage) GetAddress ¶
func (*Storage) GetCredentials ¶
func (x *Storage) GetCredentials() []*Credential
func (*Storage) GetProvider ¶
func (x *Storage) GetProvider() Storage_Provider
func (*Storage) ProtoMessage ¶
func (*Storage) ProtoMessage()
func (*Storage) ProtoReflect ¶
func (x *Storage) ProtoReflect() protoreflect.Message
type Storage_Provider ¶
type Storage_Provider int32
const ( Storage_Other Storage_Provider = 0 Storage_Ceph Storage_Provider = 1 Storage_Minio Storage_Provider = 2 Storage_AWS Storage_Provider = 3 Storage_GCS Storage_Provider = 4 Storage_Alibaba Storage_Provider = 5 Storage_Cloudflare Storage_Provider = 6 Storage_DigitalOcean Storage_Provider = 7 )
func (Storage_Provider) Descriptor ¶
func (Storage_Provider) Descriptor() protoreflect.EnumDescriptor
func (Storage_Provider) Enum ¶
func (x Storage_Provider) Enum() *Storage_Provider
func (Storage_Provider) EnumDescriptor
deprecated
func (Storage_Provider) EnumDescriptor() ([]byte, []int)
Deprecated: Use Storage_Provider.Descriptor instead.
func (Storage_Provider) Number ¶
func (x Storage_Provider) Number() protoreflect.EnumNumber
func (Storage_Provider) String ¶
func (x Storage_Provider) String() string
func (Storage_Provider) Type ¶
func (Storage_Provider) Type() protoreflect.EnumType
type SwitchMainBucketRequest ¶ added in v0.5.2
type SwitchMainBucketRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Bucket string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"` NewMain string `protobuf:"bytes,3,opt,name=new_main,json=newMain,proto3" json:"new_main,omitempty"` // contains filtered or unexported fields }
func (*SwitchMainBucketRequest) Descriptor
deprecated
added in
v0.5.2
func (*SwitchMainBucketRequest) Descriptor() ([]byte, []int)
Deprecated: Use SwitchMainBucketRequest.ProtoReflect.Descriptor instead.
func (*SwitchMainBucketRequest) GetBucket ¶ added in v0.5.2
func (x *SwitchMainBucketRequest) GetBucket() string
func (*SwitchMainBucketRequest) GetNewMain ¶ added in v0.5.2
func (x *SwitchMainBucketRequest) GetNewMain() string
func (*SwitchMainBucketRequest) GetUser ¶ added in v0.5.2
func (x *SwitchMainBucketRequest) GetUser() string
func (*SwitchMainBucketRequest) ProtoMessage ¶ added in v0.5.2
func (*SwitchMainBucketRequest) ProtoMessage()
func (*SwitchMainBucketRequest) ProtoReflect ¶ added in v0.5.2
func (x *SwitchMainBucketRequest) ProtoReflect() protoreflect.Message
func (*SwitchMainBucketRequest) Reset ¶ added in v0.5.2
func (x *SwitchMainBucketRequest) Reset()
func (*SwitchMainBucketRequest) String ¶ added in v0.5.2
func (x *SwitchMainBucketRequest) String() string
type UnimplementedChorusServer ¶
type UnimplementedChorusServer struct { }
UnimplementedChorusServer should be embedded to have forward compatible implementations.
func (UnimplementedChorusServer) AddReplication ¶
func (UnimplementedChorusServer) AddReplication(context.Context, *AddReplicationRequest) (*emptypb.Empty, error)
func (UnimplementedChorusServer) CompareBucket ¶
func (UnimplementedChorusServer) CompareBucket(context.Context, *CompareBucketRequest) (*CompareBucketResponse, error)
func (UnimplementedChorusServer) DeleteReplication ¶
func (UnimplementedChorusServer) DeleteReplication(context.Context, *ReplicationRequest) (*emptypb.Empty, error)
func (UnimplementedChorusServer) DeleteUserReplication ¶
func (UnimplementedChorusServer) DeleteUserReplication(context.Context, *DeleteUserReplicationRequest) (*emptypb.Empty, error)
func (UnimplementedChorusServer) GetAgents ¶
func (UnimplementedChorusServer) GetAgents(context.Context, *emptypb.Empty) (*GetAgentsResponse, error)
func (UnimplementedChorusServer) GetProxyCredentials ¶
func (UnimplementedChorusServer) GetProxyCredentials(context.Context, *emptypb.Empty) (*GetProxyCredentialsResponse, error)
func (UnimplementedChorusServer) GetStorages ¶
func (UnimplementedChorusServer) GetStorages(context.Context, *emptypb.Empty) (*GetStoragesResponse, error)
func (UnimplementedChorusServer) ListBucketsForReplication ¶
func (UnimplementedChorusServer) ListBucketsForReplication(context.Context, *ListBucketsForReplicationRequest) (*ListBucketsForReplicationResponse, error)
func (UnimplementedChorusServer) ListReplications ¶
func (UnimplementedChorusServer) ListReplications(context.Context, *emptypb.Empty) (*ListReplicationsResponse, error)
func (UnimplementedChorusServer) ListUserReplications ¶
func (UnimplementedChorusServer) ListUserReplications(context.Context, *emptypb.Empty) (*ListUserReplicationsResponse, error)
func (UnimplementedChorusServer) PauseReplication ¶
func (UnimplementedChorusServer) PauseReplication(context.Context, *ReplicationRequest) (*emptypb.Empty, error)
func (UnimplementedChorusServer) ResumeReplication ¶
func (UnimplementedChorusServer) ResumeReplication(context.Context, *ReplicationRequest) (*emptypb.Empty, error)
func (UnimplementedChorusServer) StreamBucketReplication ¶
func (UnimplementedChorusServer) StreamBucketReplication(*ReplicationRequest, Chorus_StreamBucketReplicationServer) error
func (UnimplementedChorusServer) SwitchMainBucket ¶ added in v0.5.2
func (UnimplementedChorusServer) SwitchMainBucket(context.Context, *SwitchMainBucketRequest) (*emptypb.Empty, error)
type UnsafeChorusServer ¶
type UnsafeChorusServer interface {
// contains filtered or unexported methods
}
UnsafeChorusServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChorusServer will result in compilation errors.
type UserReplication ¶
type UserReplication struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` To string `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"` // contains filtered or unexported fields }
func (*UserReplication) Descriptor
deprecated
func (*UserReplication) Descriptor() ([]byte, []int)
Deprecated: Use UserReplication.ProtoReflect.Descriptor instead.
func (*UserReplication) GetFrom ¶
func (x *UserReplication) GetFrom() string
func (*UserReplication) GetTo ¶
func (x *UserReplication) GetTo() string
func (*UserReplication) GetUser ¶
func (x *UserReplication) GetUser() string
func (*UserReplication) ProtoMessage ¶
func (*UserReplication) ProtoMessage()
func (*UserReplication) ProtoReflect ¶
func (x *UserReplication) ProtoReflect() protoreflect.Message
func (*UserReplication) Reset ¶
func (x *UserReplication) Reset()
func (*UserReplication) String ¶
func (x *UserReplication) String() string