api

type ActivateUsersRequest struct {
	UserId  string
	Version int
}

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

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

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 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 CreateRolesRequest struct {
	Roles        map[string][]authorization.Policy
	RoleCreation bool
	Version      int
}

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

type DeleteClassRequest struct {
	Name string
}

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 QueryGetRolesForUserRequest struct {
	User     string
	UserType models.UserTypeInput
}

type QueryGetRolesForUserResponse 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 models.UserTypeInput
}

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 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.TenantResponse
}

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 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 RevokeRolesForUserRequest struct {
	User    string
	Roles   []string
	Version int
}

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

type SuspendUserRequest struct {
	UserId    string
	RevokeKey bool
	Version   int
}

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"`
	// contains filtered or unexported fields
}