Documentation
¶
Index ¶
- Variables
- func RegisterRbacInternalServiceServer(s grpc.ServiceRegistrar, srv RbacInternalServiceServer)
- type AuthorizeRequest
- func (*AuthorizeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuthorizeRequest) GetAccessResource() string
- func (x *AuthorizeRequest) GetCapability() string
- func (x *AuthorizeRequest) GetOrganizationId() string
- func (x *AuthorizeRequest) GetProjectId() string
- func (x *AuthorizeRequest) GetToken() string
- func (*AuthorizeRequest) ProtoMessage()
- func (x *AuthorizeRequest) ProtoReflect() protoreflect.Message
- func (x *AuthorizeRequest) Reset()
- func (x *AuthorizeRequest) String() string
- type AuthorizeResponse
- func (*AuthorizeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuthorizeResponse) GetAuthorized() bool
- func (x *AuthorizeResponse) GetOrganization() *Organization
- func (x *AuthorizeResponse) GetProject() *Project
- func (x *AuthorizeResponse) GetTenantId() string
- func (x *AuthorizeResponse) GetUser() *User
- func (*AuthorizeResponse) ProtoMessage()
- func (x *AuthorizeResponse) ProtoReflect() protoreflect.Message
- func (x *AuthorizeResponse) Reset()
- func (x *AuthorizeResponse) String() string
- type AuthorizeWorkerRequest
- func (*AuthorizeWorkerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuthorizeWorkerRequest) GetToken() string
- func (*AuthorizeWorkerRequest) ProtoMessage()
- func (x *AuthorizeWorkerRequest) ProtoReflect() protoreflect.Message
- func (x *AuthorizeWorkerRequest) Reset()
- func (x *AuthorizeWorkerRequest) String() string
- type AuthorizeWorkerResponse
- func (*AuthorizeWorkerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuthorizeWorkerResponse) GetAuthorized() bool
- func (x *AuthorizeWorkerResponse) GetCluster() *Cluster
- func (x *AuthorizeWorkerResponse) GetTenantId() string
- func (*AuthorizeWorkerResponse) ProtoMessage()
- func (x *AuthorizeWorkerResponse) ProtoReflect() protoreflect.Message
- func (x *AuthorizeWorkerResponse) Reset()
- func (x *AuthorizeWorkerResponse) String() string
- type Cluster
- type Organization
- type Project
- func (*Project) Descriptor() ([]byte, []int)deprecated
- func (x *Project) GetAssignedKubernetesEnvs() []*Project_AssignedKubernetesEnv
- func (x *Project) GetId() string
- func (*Project) ProtoMessage()
- func (x *Project) ProtoReflect() protoreflect.Message
- func (x *Project) Reset()
- func (x *Project) String() string
- type Project_AssignedKubernetesEnv
- func (*Project_AssignedKubernetesEnv) Descriptor() ([]byte, []int)deprecated
- func (x *Project_AssignedKubernetesEnv) GetClusterId() string
- func (x *Project_AssignedKubernetesEnv) GetNamespace() string
- func (*Project_AssignedKubernetesEnv) ProtoMessage()
- func (x *Project_AssignedKubernetesEnv) ProtoReflect() protoreflect.Message
- func (x *Project_AssignedKubernetesEnv) Reset()
- func (x *Project_AssignedKubernetesEnv) String() string
- type RbacInternalServiceClient
- type RbacInternalServiceServer
- type UnimplementedRbacInternalServiceServer
- type UnsafeRbacInternalServiceServer
- type User
Constants ¶
This section is empty.
Variables ¶
var File_api_v1_rbac_manager_service_proto protoreflect.FileDescriptor
var RbacInternalService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "llmoperator.rbac.server.v1.RbacInternalService", HandlerType: (*RbacInternalServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Authorize", Handler: _RbacInternalService_Authorize_Handler, }, { MethodName: "AuthorizeWorker", Handler: _RbacInternalService_AuthorizeWorker_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/v1/rbac_manager_service.proto", }
RbacInternalService_ServiceDesc is the grpc.ServiceDesc for RbacInternalService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRbacInternalServiceServer ¶
func RegisterRbacInternalServiceServer(s grpc.ServiceRegistrar, srv RbacInternalServiceServer)
Types ¶
type AuthorizeRequest ¶
type AuthorizeRequest struct {
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
AccessResource string `protobuf:"bytes,2,opt,name=access_resource,json=accessResource,proto3" json:"access_resource,omitempty"`
Capability string `protobuf:"bytes,3,opt,name=capability,proto3" json:"capability,omitempty"`
OrganizationId string `protobuf:"bytes,4,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
ProjectId string `protobuf:"bytes,5,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
// contains filtered or unexported fields
}
func (*AuthorizeRequest) Descriptor
deprecated
func (*AuthorizeRequest) Descriptor() ([]byte, []int)
Deprecated: Use AuthorizeRequest.ProtoReflect.Descriptor instead.
func (*AuthorizeRequest) GetAccessResource ¶ added in v0.34.0
func (x *AuthorizeRequest) GetAccessResource() string
func (*AuthorizeRequest) GetCapability ¶ added in v0.34.0
func (x *AuthorizeRequest) GetCapability() string
func (*AuthorizeRequest) GetOrganizationId ¶ added in v0.34.0
func (x *AuthorizeRequest) GetOrganizationId() string
func (*AuthorizeRequest) GetProjectId ¶ added in v0.34.0
func (x *AuthorizeRequest) GetProjectId() string
func (*AuthorizeRequest) GetToken ¶
func (x *AuthorizeRequest) GetToken() string
func (*AuthorizeRequest) ProtoMessage ¶
func (*AuthorizeRequest) ProtoMessage()
func (*AuthorizeRequest) ProtoReflect ¶
func (x *AuthorizeRequest) ProtoReflect() protoreflect.Message
func (*AuthorizeRequest) Reset ¶
func (x *AuthorizeRequest) Reset()
func (*AuthorizeRequest) String ¶
func (x *AuthorizeRequest) String() string
type AuthorizeResponse ¶
type AuthorizeResponse struct {
Authorized bool `protobuf:"varint,1,opt,name=authorized,proto3" json:"authorized,omitempty"`
User *User `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
Organization *Organization `protobuf:"bytes,3,opt,name=organization,proto3" json:"organization,omitempty"`
Project *Project `protobuf:"bytes,4,opt,name=project,proto3" json:"project,omitempty"`
TenantId string `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
// contains filtered or unexported fields
}
func (*AuthorizeResponse) Descriptor
deprecated
func (*AuthorizeResponse) Descriptor() ([]byte, []int)
Deprecated: Use AuthorizeResponse.ProtoReflect.Descriptor instead.
func (*AuthorizeResponse) GetAuthorized ¶
func (x *AuthorizeResponse) GetAuthorized() bool
func (*AuthorizeResponse) GetOrganization ¶ added in v0.23.0
func (x *AuthorizeResponse) GetOrganization() *Organization
func (*AuthorizeResponse) GetProject ¶ added in v0.34.0
func (x *AuthorizeResponse) GetProject() *Project
func (*AuthorizeResponse) GetTenantId ¶ added in v0.63.0
func (x *AuthorizeResponse) GetTenantId() string
func (*AuthorizeResponse) GetUser ¶ added in v0.23.0
func (x *AuthorizeResponse) GetUser() *User
func (*AuthorizeResponse) ProtoMessage ¶
func (*AuthorizeResponse) ProtoMessage()
func (*AuthorizeResponse) ProtoReflect ¶
func (x *AuthorizeResponse) ProtoReflect() protoreflect.Message
func (*AuthorizeResponse) Reset ¶
func (x *AuthorizeResponse) Reset()
func (*AuthorizeResponse) String ¶
func (x *AuthorizeResponse) String() string
type AuthorizeWorkerRequest ¶ added in v0.66.0
type AuthorizeWorkerRequest struct {
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
// contains filtered or unexported fields
}
func (*AuthorizeWorkerRequest) Descriptor
deprecated
added in
v0.66.0
func (*AuthorizeWorkerRequest) Descriptor() ([]byte, []int)
Deprecated: Use AuthorizeWorkerRequest.ProtoReflect.Descriptor instead.
func (*AuthorizeWorkerRequest) GetToken ¶ added in v0.66.0
func (x *AuthorizeWorkerRequest) GetToken() string
func (*AuthorizeWorkerRequest) ProtoMessage ¶ added in v0.66.0
func (*AuthorizeWorkerRequest) ProtoMessage()
func (*AuthorizeWorkerRequest) ProtoReflect ¶ added in v0.66.0
func (x *AuthorizeWorkerRequest) ProtoReflect() protoreflect.Message
func (*AuthorizeWorkerRequest) Reset ¶ added in v0.66.0
func (x *AuthorizeWorkerRequest) Reset()
func (*AuthorizeWorkerRequest) String ¶ added in v0.66.0
func (x *AuthorizeWorkerRequest) String() string
type AuthorizeWorkerResponse ¶ added in v0.66.0
type AuthorizeWorkerResponse struct {
Authorized bool `protobuf:"varint,1,opt,name=authorized,proto3" json:"authorized,omitempty"`
Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
TenantId string `protobuf:"bytes,3,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
// contains filtered or unexported fields
}
func (*AuthorizeWorkerResponse) Descriptor
deprecated
added in
v0.66.0
func (*AuthorizeWorkerResponse) Descriptor() ([]byte, []int)
Deprecated: Use AuthorizeWorkerResponse.ProtoReflect.Descriptor instead.
func (*AuthorizeWorkerResponse) GetAuthorized ¶ added in v0.67.0
func (x *AuthorizeWorkerResponse) GetAuthorized() bool
func (*AuthorizeWorkerResponse) GetCluster ¶ added in v0.67.0
func (x *AuthorizeWorkerResponse) GetCluster() *Cluster
func (*AuthorizeWorkerResponse) GetTenantId ¶ added in v0.66.0
func (x *AuthorizeWorkerResponse) GetTenantId() string
func (*AuthorizeWorkerResponse) ProtoMessage ¶ added in v0.66.0
func (*AuthorizeWorkerResponse) ProtoMessage()
func (*AuthorizeWorkerResponse) ProtoReflect ¶ added in v0.66.0
func (x *AuthorizeWorkerResponse) ProtoReflect() protoreflect.Message
func (*AuthorizeWorkerResponse) Reset ¶ added in v0.66.0
func (x *AuthorizeWorkerResponse) Reset()
func (*AuthorizeWorkerResponse) String ¶ added in v0.66.0
func (x *AuthorizeWorkerResponse) String() string
type Cluster ¶ added in v0.67.0
type Cluster struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*Cluster) Descriptor
deprecated
added in
v0.67.0
func (*Cluster) ProtoMessage ¶ added in v0.67.0
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶ added in v0.67.0
func (x *Cluster) ProtoReflect() protoreflect.Message
type Organization ¶ added in v0.23.0
type Organization struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*Organization) Descriptor
deprecated
added in
v0.23.0
func (*Organization) Descriptor() ([]byte, []int)
Deprecated: Use Organization.ProtoReflect.Descriptor instead.
func (*Organization) GetId ¶ added in v0.23.0
func (x *Organization) GetId() string
func (*Organization) ProtoMessage ¶ added in v0.23.0
func (*Organization) ProtoMessage()
func (*Organization) ProtoReflect ¶ added in v0.23.0
func (x *Organization) ProtoReflect() protoreflect.Message
func (*Organization) Reset ¶ added in v0.23.0
func (x *Organization) Reset()
func (*Organization) String ¶ added in v0.23.0
func (x *Organization) String() string
type Project ¶ added in v0.34.0
type Project struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
AssignedKubernetesEnvs []*Project_AssignedKubernetesEnv `` /* 129-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*Project) Descriptor
deprecated
added in
v0.34.0
func (*Project) GetAssignedKubernetesEnvs ¶ added in v0.73.0
func (x *Project) GetAssignedKubernetesEnvs() []*Project_AssignedKubernetesEnv
func (*Project) ProtoMessage ¶ added in v0.34.0
func (*Project) ProtoMessage()
func (*Project) ProtoReflect ¶ added in v0.34.0
func (x *Project) ProtoReflect() protoreflect.Message
type Project_AssignedKubernetesEnv ¶ added in v0.73.0
type Project_AssignedKubernetesEnv struct {
ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
// contains filtered or unexported fields
}
func (*Project_AssignedKubernetesEnv) Descriptor
deprecated
added in
v0.73.0
func (*Project_AssignedKubernetesEnv) Descriptor() ([]byte, []int)
Deprecated: Use Project_AssignedKubernetesEnv.ProtoReflect.Descriptor instead.
func (*Project_AssignedKubernetesEnv) GetClusterId ¶ added in v0.73.0
func (x *Project_AssignedKubernetesEnv) GetClusterId() string
func (*Project_AssignedKubernetesEnv) GetNamespace ¶ added in v0.73.0
func (x *Project_AssignedKubernetesEnv) GetNamespace() string
func (*Project_AssignedKubernetesEnv) ProtoMessage ¶ added in v0.73.0
func (*Project_AssignedKubernetesEnv) ProtoMessage()
func (*Project_AssignedKubernetesEnv) ProtoReflect ¶ added in v0.73.0
func (x *Project_AssignedKubernetesEnv) ProtoReflect() protoreflect.Message
func (*Project_AssignedKubernetesEnv) Reset ¶ added in v0.73.0
func (x *Project_AssignedKubernetesEnv) Reset()
func (*Project_AssignedKubernetesEnv) String ¶ added in v0.73.0
func (x *Project_AssignedKubernetesEnv) String() string
type RbacInternalServiceClient ¶
type RbacInternalServiceClient interface {
Authorize(ctx context.Context, in *AuthorizeRequest, opts ...grpc.CallOption) (*AuthorizeResponse, error)
// AuthorizeWorker authorizes requests from worker clusters.
AuthorizeWorker(ctx context.Context, in *AuthorizeWorkerRequest, opts ...grpc.CallOption) (*AuthorizeWorkerResponse, error)
}
RbacInternalServiceClient is the client API for RbacInternalService 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 NewRbacInternalServiceClient ¶
func NewRbacInternalServiceClient(cc grpc.ClientConnInterface) RbacInternalServiceClient
type RbacInternalServiceServer ¶
type RbacInternalServiceServer interface {
Authorize(context.Context, *AuthorizeRequest) (*AuthorizeResponse, error)
// AuthorizeWorker authorizes requests from worker clusters.
AuthorizeWorker(context.Context, *AuthorizeWorkerRequest) (*AuthorizeWorkerResponse, error)
// contains filtered or unexported methods
}
RbacInternalServiceServer is the server API for RbacInternalService service. All implementations must embed UnimplementedRbacInternalServiceServer for forward compatibility
type UnimplementedRbacInternalServiceServer ¶
type UnimplementedRbacInternalServiceServer struct {
}
UnimplementedRbacInternalServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedRbacInternalServiceServer) Authorize ¶
func (UnimplementedRbacInternalServiceServer) Authorize(context.Context, *AuthorizeRequest) (*AuthorizeResponse, error)
func (UnimplementedRbacInternalServiceServer) AuthorizeWorker ¶ added in v0.66.0
func (UnimplementedRbacInternalServiceServer) AuthorizeWorker(context.Context, *AuthorizeWorkerRequest) (*AuthorizeWorkerResponse, error)
type UnsafeRbacInternalServiceServer ¶
type UnsafeRbacInternalServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRbacInternalServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RbacInternalServiceServer will result in compilation errors.
type User ¶ added in v0.23.0
type User struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*User) Descriptor
deprecated
added in
v0.23.0
func (*User) ProtoMessage ¶ added in v0.23.0
func (*User) ProtoMessage()
func (*User) ProtoReflect ¶ added in v0.23.0
func (x *User) ProtoReflect() protoreflect.Message