pb

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
}

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
}

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

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

type Chorus_StreamBucketReplicationClient interface {
	Recv() (*Replication, error)
	grpc.ClientStream
}

type Chorus_StreamBucketReplicationServer interface {
	Send(*Replication) error
	grpc.ServerStream
}

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
}

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
}

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
}

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
}

type GetAgentsResponse struct {
	Agents []*Agent `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

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
}

type GetStoragesResponse struct {
	Storages []*Storage `protobuf:"bytes,1,rep,name=storages,proto3" json:"storages,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

type ListReplicationsResponse struct {
	Replications []*Replication `protobuf:"bytes,1,rep,name=replications,proto3" json:"replications,omitempty"`
	// contains filtered or unexported fields
}

type ListUserReplicationsResponse struct {
	Replications []*UserReplication `protobuf:"bytes,1,rep,name=replications,proto3" json:"replications,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

type Replication_SwitchEnum int32

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
}

type Storage_Provider int32

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
}

type UnimplementedChorusServer struct {
}

type UnsafeChorusServer interface {
	// contains filtered or unexported methods
}

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
}