api

type ActivateUsersRequest struct {
	UserId  string
	Version int
}

type AddClassRequest struct {
	Class *models.Class
	State *sharding.State
}

type AddDistributedTaskRequest struct {
	Namespace             string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Id                    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Payload               []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	SubmittedAtUnixMillis int64  `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AddPropertyRequest struct {
	Properties []*models.Property
}

type AddReplicaToShard struct {
	Class, Shard, TargetNode string
	SchemaVersion            uint64
}

type AddRolesForUsersRequest struct {
	User    string
	Roles   []string
	Version int
}

type AddTenantsRequest struct {
	ClusterNodes []string  `protobuf:"bytes,1,rep,name=cluster_nodes,json=clusterNodes,proto3" json:"cluster_nodes,omitempty"`
	Tenants      []*Tenant `protobuf:"bytes,2,rep,name=tenants,proto3" json:"tenants,omitempty"`
	// contains filtered or unexported fields
}

type ApplyRequest struct {
	Type       ApplyRequest_Type `protobuf:"varint,1,opt,name=type,proto3,enum=weaviate.internal.cluster.ApplyRequest_Type" json:"type,omitempty"`
	Class      string            `protobuf:"bytes,2,opt,name=class,proto3" json:"class,omitempty"`
	Version    uint64            `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	SubCommand []byte            `protobuf:"bytes,4,opt,name=sub_command,json=subCommand,proto3" json:"sub_command,omitempty"`
	// contains filtered or unexported fields
}

type ApplyRequest_Type int32

type ApplyResponse struct {
	Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Leader  string `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

type CancelDistributedTaskRequest struct {
	Namespace             string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Id                    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Version               uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	CancelledAtUnixMillis int64  `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CleanUpDistributedTaskRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Id        string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Version   uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type ClusterServiceClient interface {
	RemovePeer(ctx context.Context, in *RemovePeerRequest, opts ...grpc.CallOption) (*RemovePeerResponse, error)
	JoinPeer(ctx context.Context, in *JoinPeerRequest, opts ...grpc.CallOption) (*JoinPeerResponse, error)
	NotifyPeer(ctx context.Context, in *NotifyPeerRequest, opts ...grpc.CallOption) (*NotifyPeerResponse, error)
	Apply(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
}

type ClusterServiceServer interface {
	RemovePeer(context.Context, *RemovePeerRequest) (*RemovePeerResponse, error)
	JoinPeer(context.Context, *JoinPeerRequest) (*JoinPeerResponse, error)
	NotifyPeer(context.Context, *NotifyPeerRequest) (*NotifyPeerResponse, error)
	Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
}

type CreateAliasRequest struct {
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Alias      string `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

type CreateRolesRequest struct {
	Roles        map[string][]authorization.Policy
	RoleCreation bool
	Version      int
}

type CreateUserWithKeyRequest struct {
	UserId             string
	ApiKeyFirstLetters string
	WeakHash           [sha256.Size]byte
	CreatedAt          time.Time
	Version            int
}

type CreateUsersRequest struct {
	UserId             string
	SecureHash         string
	UserIdentifier     string
	ApiKeyFirstLetters string
	CreatedAt          time.Time
	Version            int
}

type DeleteAliasRequest struct {
	Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

type DeleteClassRequest struct {
	Name string
}

type DeleteReplicaFromShard struct {
	Class, Shard, TargetNode string
	SchemaVersion            uint64
}

type DeleteRolesRequest struct {
	Roles []string
}

type DeleteTenantsRequest struct {
	Tenants []string `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"`
	// contains filtered or unexported fields
}

type DeleteUsersRequest struct {
	UserId  string
	Version int
}

type JoinPeerRequest struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Voter   bool   `protobuf:"varint,3,opt,name=voter,proto3" json:"voter,omitempty"`
	// contains filtered or unexported fields
}

type JoinPeerResponse struct {
	Leader string `protobuf:"bytes,1,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

type NotifyPeerRequest struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

type NotifyPeerResponse struct {
	// contains filtered or unexported fields
}

type QueryClassVersionsRequest struct {
	Classes []string
}

type QueryClassVersionsResponse struct {
	// Classes is a map of class name to the class version
	Classes map[string]uint64
}

type QueryCollectionsCountResponse struct {
	Count int
}

type QueryGetAliasesRequest struct {
	Alias, Class string
}

type QueryGetAliasesResponse struct {
	Aliases map[string]string
}

type QueryGetAllUsersOrGroupsWithRolesRequest struct {
	IsGroup  bool
	AuthType authentication.AuthType
}

type QueryGetAllUsersOrGroupsWithRolesResponse struct {
	UsersOrGroups []string
}

type QueryGetRolesForUserOrGroupRequest struct {
	User     string
	UserType authentication.AuthType
	IsGroup  bool
}

type QueryGetRolesForUserOrGroupResponse struct {
	Roles map[string][]authorization.Policy
}

type QueryGetRolesRequest struct {
	Roles []string
}

type QueryGetRolesResponse struct {
	Roles map[string][]authorization.Policy
}

type QueryGetUsersForRoleRequest struct {
	Role     string
	UserType authentication.AuthType
	IsGroup  bool
}

type QueryGetUsersForRoleResponse struct {
	Users []string
}

type QueryGetUsersRequest struct {
	UserIds []string
}

type QueryGetUsersResponse struct {
	Users map[string]*apikey.User
}

type QueryHasPermissionRequest struct {
	Role       string
	Permission *authorization.Policy
}

type QueryHasPermissionResponse struct {
	HasPermission bool
}

type QueryReadOnlyClassResponse struct {
	Classes map[string]versioned.Class
}

type QueryReadOnlyClassesRequest struct {
	Classes []string
}

type QueryRequest struct {
	Type       QueryRequest_Type `protobuf:"varint,1,opt,name=type,proto3,enum=weaviate.internal.cluster.QueryRequest_Type" json:"type,omitempty"`
	SubCommand []byte            `protobuf:"bytes,2,opt,name=sub_command,json=subCommand,proto3" json:"sub_command,omitempty"`
	// contains filtered or unexported fields
}

type QueryRequest_Type int32

type QueryResolveAliasRequest struct {
	Alias string
}

type QueryResolveAliasResponse struct {
	Class string
}

type QueryResponse struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type QuerySchemaResponse struct {
	Schema models.Schema
}

type QueryShardOwnerRequest struct {
	Class, Shard string
}

type QueryShardOwnerResponse struct {
	ShardVersion uint64
	Owner        string
}

type QueryShardingStateRequest struct {
	Class string
}

type QueryShardingStateResponse struct {
	State   *sharding.State
	Version uint64
}

type QueryTenantsRequest struct {
	Class   string
	Tenants []string // If empty, all tenants are returned
}

type QueryTenantsResponse struct {
	ShardVersion uint64
	Tenants      []*models.Tenant
}

type QueryTenantsShardsRequest struct {
	Class   string
	Tenants []string
}

type QueryTenantsShardsResponse struct {
	TenantsActivityStatus map[string]string // map[tenant]status
	SchemaVersion         uint64
}

type QueryUserIdentifierExistsRequest struct {
	UserIdentifier string
}

type QueryUserIdentifierExistsResponse struct {
	Exists bool
}

type RecordDistributedTaskNodeCompletionRequest struct {
	Namespace            string  `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Id                   string  `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Version              uint64  `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	NodeId               string  `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Error                *string `protobuf:"bytes,5,opt,name=error,proto3,oneof" json:"error,omitempty"`
	FinishedAtUnixMillis int64   `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RemovePeerRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type RemovePeerResponse struct {
	Leader string `protobuf:"bytes,1,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

type RemovePermissionsRequest struct {
	Role        string
	Permissions []*authorization.Policy
	Version     int
}

type ReplaceAliasRequest struct {
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Alias      string `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

type ReplicationAddReplicaToShard struct {
	OpId                     uint64
	Class, Shard, TargetNode string
	SchemaVersion            uint64
}

type ReplicationCancelRequest struct {
	Version int
	Uuid    strfmt.UUID
}

type ReplicationCancellationCompleteRequest struct {
	Version int
	Id      uint64
}

type ReplicationDeleteAllRequest struct {
	Version int
}

type ReplicationDeleteOpResponse struct{}

type ReplicationDeleteRequest struct {
	Version int
	Uuid    strfmt.UUID
}

type ReplicationDetailsError struct {
	Message           string
	ErroredTimeUnixMs int64 // Unix timestamp in milliseconds when the error occurred
}

type ReplicationDetailsRequest struct {
	Uuid strfmt.UUID
}

type ReplicationDetailsRequestByCollection struct {
	Collection string
}

type ReplicationDetailsRequestByCollectionAndShard struct {
	Collection string
	Shard      string
}

type ReplicationDetailsRequestByTargetNode struct {
	Node string
}

type ReplicationDetailsResponse struct {
	Uuid         strfmt.UUID
	Id           uint64
	ShardId      string
	Collection   string
	SourceNodeId string
	TargetNodeId string

	Uncancelable       bool
	ScheduledForCancel bool
	ScheduledForDelete bool

	Status          ReplicationDetailsState
	StatusHistory   []ReplicationDetailsState
	TransferType    string
	StartTimeUnixMs int64
}

type ReplicationDetailsState struct {
	State           string
	Errors          []ReplicationDetailsError
	StartTimeUnixMs int64 // Unix timestamp in milliseconds when the state was first entered
}

type ReplicationForceDeleteAllRequest struct{}

type ReplicationForceDeleteByCollectionAndShardRequest struct {
	Collection string
	Shard      string
}

type ReplicationForceDeleteByCollectionRequest struct {
	Collection string
}

type ReplicationForceDeleteByTargetNodeRequest struct {
	Node string
}

type ReplicationForceDeleteByUuidRequest struct {
	Uuid strfmt.UUID
}

type ReplicationOperationStateRequest struct {
	Id uint64
}

type ReplicationOperationStateResponse struct {
	State ShardReplicationState
}

type ReplicationPurgeRequest struct {
	Version int
}

type ReplicationQueryShardingStateByCollectionAndShardRequest struct {
	Collection string
	Shard      string
}

type ReplicationQueryShardingStateByCollectionRequest struct {
	Collection string
}

type ReplicationRegisterErrorRequest struct {
	Version int

	Id         uint64
	Error      string
	TimeUnixMs int64
}

type ReplicationRegisterErrorResponse struct{}

type ReplicationRemoveOpRequest struct {
	Version int

	Id uint64
}

type ReplicationReplicateShardReponse struct{}

type ReplicationReplicateShardRequest struct {
	// Version is the version with which this command was generated
	Version int

	Uuid strfmt.UUID

	SourceNode       string
	SourceCollection string
	SourceShard      string
	TargetNode       string

	TransferType string
}

type ReplicationStoreSchemaVersionRequest struct {
	Version       int
	SchemaVersion uint64
	Id            uint64
}

type ReplicationUpdateOpStateRequest struct {
	Version int

	Id    uint64
	State ShardReplicationState
}

type ReplicationUpdateOpStateResponse struct{}

type ReplicationsDeleteByCollectionRequest struct {
	Version    int
	Collection string
}

type ReplicationsDeleteByTenantsRequest struct {
	Version    int
	Collection string
	Tenants    []string
}

type RevokeRolesForUserRequest struct {
	User    string
	Roles   []string
	Version int
}

type RotateUserApiKeyRequest struct {
	UserId             string
	ApiKeyFirstLetters string
	SecureHash         string
	OldIdentifier      string
	NewIdentifier      string
	Version            int
}

type ShardReplicationState string

type ShardReplicationTransferType string

type ShardingState struct {
	Collection string
	Shards     map[string][]string
}

type SuspendUserRequest struct {
	UserId    string
	RevokeKey bool
	Version   int
}

type SyncShardRequest struct {
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Shard      string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	NodeId     string `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

type Tenant struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type TenantProcessRequest struct {
	Node             string                      `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Action           TenantProcessRequest_Action `protobuf:"varint,2,opt,name=action,proto3,enum=weaviate.internal.cluster.TenantProcessRequest_Action" json:"action,omitempty"`
	TenantsProcesses []*TenantsProcess           `protobuf:"bytes,3,rep,name=tenants_processes,json=tenantsProcesses,proto3" json:"tenants_processes,omitempty"`
	// contains filtered or unexported fields
}

type TenantProcessRequest_Action int32

type TenantWithVersion struct {
	ShardVersion uint64
	Tenant       *models.Tenant
}

type TenantsProcess struct {
	Op     TenantsProcess_Op `protobuf:"varint,1,opt,name=op,proto3,enum=weaviate.internal.cluster.TenantsProcess_Op" json:"op,omitempty"`
	Tenant *Tenant           `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

type TenantsProcess_Op int32

type UnimplementedClusterServiceServer struct {
}

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

type UpdateClassRequest struct {
	Class *models.Class
	State *sharding.State
}

type UpdateShardStatusRequest struct {
	Class, Shard, Status string
	SchemaVersion        uint64
}

type UpdateTenantsRequest struct {
	Tenants               []*Tenant `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"`
	ClusterNodes          []string  `protobuf:"bytes,2,rep,name=cluster_nodes,json=clusterNodes,proto3" json:"cluster_nodes,omitempty"`
	ImplicitUpdateRequest bool      `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}