gravitational/teleport
1
0
Fork 0
mirror of https://github.com/gravitational/teleport.git synced 2026-10-12 02:15:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add Classifier create, update, and upsert RPCs (#67760)

Browse Source
This commit is contained in:
Ryan Clark
2026-06-16 12:43:05 +00:00
committed by GitHub
parent a2058ab07a
commit bb018b13d2
7 changed files with 1636 additions and 428 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/client/proto/event.pb.go
+60 -7
View File
@@ -214,6 +214,7 @@ type Event struct {
// *Event_Beam
// *Event_ValidatedMFAChallengeV2
// *Event_BeamsConfig
// *Event_Classifier
Resource isEvent_Resource `protobuf_oneof:"Resource"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
@@ -1078,6 +1079,15 @@ func (x *Event) GetBeamsConfig() *v125.BeamsConfig {
return nil
}
func (x *Event) GetClassifier() *v124.Classifier {
if x != nil {
if x, ok := x.Resource.(*Event_Classifier); ok {
return x.Classifier
}
}
return nil
}
func (x *Event) SetType(v Operation) {
x.Type = v
}
@@ -1811,6 +1821,14 @@ func (x *Event) SetBeamsConfig(v *v125.BeamsConfig) {
x.Resource = &Event_BeamsConfig{v}
}
func (x *Event) SetClassifier(v *v124.Classifier) {
if v == nil {
x.Resource = nil
return
}
x.Resource = &Event_Classifier{v}
}
func (x *Event) HasResource() bool {
if x == nil {
return false
@@ -2547,6 +2565,14 @@ func (x *Event) HasBeamsConfig() bool {
return ok
}
func (x *Event) HasClassifier() bool {
if x == nil {
return false
}
_, ok := x.Resource.(*Event_Classifier)
return ok
}
func (x *Event) ClearResource() {
x.Resource = nil
}
@@ -3098,6 +3124,12 @@ func (x *Event) ClearBeamsConfig() {
}
}
func (x *Event) ClearClassifier() {
if _, ok := x.Resource.(*Event_Classifier); ok {
x.Resource = nil
}
}
const Event_Resource_not_set_case case_Event_Resource = 0
const Event_ResourceHeader_case case_Event_Resource = 2
const Event_CertAuthority_case case_Event_Resource = 3
@@ -3190,6 +3222,7 @@ const Event_RetrievalModel_case case_Event_Resource = 94
const Event_Beam_case case_Event_Resource = 95
const Event_ValidatedMFAChallengeV2_case case_Event_Resource = 96
const Event_BeamsConfig_case case_Event_Resource = 97
const Event_Classifier_case case_Event_Resource = 98
func (x *Event) WhichResource() case_Event_Resource {
if x == nil {
@@ -3378,6 +3411,8 @@ func (x *Event) WhichResource() case_Event_Resource {
return Event_ValidatedMFAChallengeV2_case
case *Event_BeamsConfig:
return Event_BeamsConfig_case
case *Event_Classifier:
return Event_Classifier_case
default:
return Event_Resource_not_set_case
}
@@ -3580,6 +3615,8 @@ type Event_builder struct {
ValidatedMFAChallengeV2 *v21.ValidatedMFAChallenge
// BeamsConfig is the user-provided configuration for Beams.
BeamsConfig *v125.BeamsConfig
// Classifier is a resource for defining session summarization classifiers.
Classifier *v124.Classifier
// -- end of Resource
}
@@ -3861,6 +3898,9 @@ func (b0 Event_builder) Build() *Event {
if b.BeamsConfig != nil {
x.Resource = &Event_BeamsConfig{b.BeamsConfig}
}
if b.Classifier != nil {
x.Resource = &Event_Classifier{b.Classifier}
}
return m0
}
@@ -4340,6 +4380,11 @@ type Event_BeamsConfig struct {
BeamsConfig *v125.BeamsConfig `protobuf:"bytes,97,opt,name=BeamsConfig,proto3,oneof"`
}
type Event_Classifier struct {
// Classifier is a resource for defining session summarization classifiers.
Classifier *v124.Classifier `protobuf:"bytes,98,opt,name=Classifier,proto3,oneof"`
}
func (*Event_ResourceHeader) isEvent_Resource() {}
func (*Event_CertAuthority) isEvent_Resource() {}
@@ -4522,11 +4567,13 @@ func (*Event_ValidatedMFAChallengeV2) isEvent_Resource() {}
func (*Event_BeamsConfig) isEvent_Resource() {}
func (*Event_Classifier) isEvent_Resource() {}
var File_teleport_legacy_client_proto_event_proto protoreflect.FileDescriptor
const file_teleport_legacy_client_proto_event_proto_rawDesc = "" +
"\n" +
"(teleport/legacy/client/proto/event.proto\x12\x05proto\x1a'teleport/accesslist/v1/accesslist.proto\x1a?teleport/accessmonitoringrules/v1/access_monitoring_rules.proto\x1a-teleport/appauthconfig/v1/appauthconfig.proto\x1a'teleport/autoupdate/v1/autoupdate.proto\x1a\x1cteleport/beams/v1/beam.proto\x1a$teleport/beams/v1/beams_config.proto\x1a5teleport/clusterconfig/v1/access_graph_settings.proto\x1a'teleport/crownjewel/v1/crownjewel.proto\x1a#teleport/dbobject/v1/dbobject.proto\x1a1teleport/discoveryconfig/v1/discoveryconfig.proto\x1a7teleport/healthcheckconfig/v1/health_check_config.proto\x1a/teleport/identitycenter/v1/identitycenter.proto\x1a;teleport/kubewaitingcontainer/v1/kubewaitingcontainer.proto\x1a!teleport/legacy/types/types.proto\x1a,teleport/linuxdesktop/v1/linux_desktop.proto\x1a(teleport/machineid/v1/bot_instance.proto\x1a&teleport/machineid/v1/federation.proto\x1a)teleport/mfa/v1/validated_challenge.proto\x1a)teleport/mfa/v2/validated_challenge.proto\x1a-teleport/notifications/v1/notifications.proto\x1a'teleport/presence/v1/relay_server.proto\x1a+teleport/provisioning/v1/provisioning.proto\x1a:teleport/recordingencryption/v1/recording_encryption.proto\x1a*teleport/scopes/access/v1/assignment.proto\x1a$teleport/scopes/access/v1/role.proto\x1a'teleport/secreports/v1/secreports.proto\x1a/teleport/subca/v1/cert_authority_override.proto\x1a'teleport/summarizer/v1/summarizer.proto\x1a/teleport/userloginstate/v1/userloginstate.proto\x1a1teleport/userprovisioning/v2/statichostuser.proto\x1a&teleport/usertasks/v1/user_tasks.proto\x1a+teleport/workloadidentity/v1/resource.proto\x1a6teleport/workloadidentity/v1/revocation_resource.proto\"\x858\n" +
"(teleport/legacy/client/proto/event.proto\x12\x05proto\x1a'teleport/accesslist/v1/accesslist.proto\x1a?teleport/accessmonitoringrules/v1/access_monitoring_rules.proto\x1a-teleport/appauthconfig/v1/appauthconfig.proto\x1a'teleport/autoupdate/v1/autoupdate.proto\x1a\x1cteleport/beams/v1/beam.proto\x1a$teleport/beams/v1/beams_config.proto\x1a5teleport/clusterconfig/v1/access_graph_settings.proto\x1a'teleport/crownjewel/v1/crownjewel.proto\x1a#teleport/dbobject/v1/dbobject.proto\x1a1teleport/discoveryconfig/v1/discoveryconfig.proto\x1a7teleport/healthcheckconfig/v1/health_check_config.proto\x1a/teleport/identitycenter/v1/identitycenter.proto\x1a;teleport/kubewaitingcontainer/v1/kubewaitingcontainer.proto\x1a!teleport/legacy/types/types.proto\x1a,teleport/linuxdesktop/v1/linux_desktop.proto\x1a(teleport/machineid/v1/bot_instance.proto\x1a&teleport/machineid/v1/federation.proto\x1a)teleport/mfa/v1/validated_challenge.proto\x1a)teleport/mfa/v2/validated_challenge.proto\x1a-teleport/notifications/v1/notifications.proto\x1a'teleport/presence/v1/relay_server.proto\x1a+teleport/provisioning/v1/provisioning.proto\x1a:teleport/recordingencryption/v1/recording_encryption.proto\x1a*teleport/scopes/access/v1/assignment.proto\x1a$teleport/scopes/access/v1/role.proto\x1a'teleport/secreports/v1/secreports.proto\x1a/teleport/subca/v1/cert_authority_override.proto\x1a'teleport/summarizer/v1/summarizer.proto\x1a/teleport/userloginstate/v1/userloginstate.proto\x1a1teleport/userprovisioning/v2/statichostuser.proto\x1a&teleport/usertasks/v1/user_tasks.proto\x1a+teleport/workloadidentity/v1/resource.proto\x1a6teleport/workloadidentity/v1/revocation_resource.proto\"\xcb8\n" +
"\x05Event\x12$\n" +
"\x04Type\x18\x01 \x01(\x0e2\x10.proto.OperationR\x04Type\x12?\n" +
"\x0eResourceHeader\x18\x02 \x01(\v2\x15.types.ResourceHeaderH\x00R\x0eResourceHeader\x12>\n" +
@@ -4632,7 +4679,10 @@ const file_teleport_legacy_client_proto_event_proto_rawDesc = "" +
"\x0eRetrievalModel\x18^ \x01(\v2&.teleport.summarizer.v1.RetrievalModelH\x00R\x0eRetrievalModel\x12-\n" +
"\x04Beam\x18_ \x01(\v2\x17.teleport.beams.v1.BeamH\x00R\x04Beam\x12b\n" +
"\x17ValidatedMFAChallengeV2\x18` \x01(\v2&.teleport.mfa.v2.ValidatedMFAChallengeH\x00R\x17ValidatedMFAChallengeV2\x12B\n" +
"\vBeamsConfig\x18a \x01(\v2\x1e.teleport.beams.v1.BeamsConfigH\x00R\vBeamsConfigB\n" +
"\vBeamsConfig\x18a \x01(\v2\x1e.teleport.beams.v1.BeamsConfigH\x00R\vBeamsConfig\x12D\n" +
"\n" +
"Classifier\x18b \x01(\v2\".teleport.summarizer.v1.ClassifierH\x00R\n" +
"ClassifierB\n" +
"\n" +
"\bResourceJ\x04\b\a\x10\bJ\x04\b1\x102J\x04\b?\x10@J\x04\bD\x10EJ\x04\bX\x10YR\x12ExternalCloudAuditR\x0eStaticHostUserR\x13AutoUpdateAgentPlanR\x0fWorkloadCluster**\n" +
"\tOperation\x12\b\n" +
@@ -4734,6 +4784,7 @@ var file_teleport_legacy_client_proto_event_proto_goTypes = []any{
(*v125.Beam)(nil), // 87: teleport.beams.v1.Beam
(*v21.ValidatedMFAChallenge)(nil), // 88: teleport.mfa.v2.ValidatedMFAChallenge
(*v125.BeamsConfig)(nil), // 89: teleport.beams.v1.BeamsConfig
(*v124.Classifier)(nil), // 90: teleport.summarizer.v1.Classifier
}
var file_teleport_legacy_client_proto_event_proto_depIdxs = []int32{
0, // 0: proto.Event.Type:type_name -> proto.Operation
@@ -4828,11 +4879,12 @@ var file_teleport_legacy_client_proto_event_proto_depIdxs = []int32{
87, // 89: proto.Event.Beam:type_name -> teleport.beams.v1.Beam
88, // 90: proto.Event.ValidatedMFAChallengeV2:type_name -> teleport.mfa.v2.ValidatedMFAChallenge
89, // 91: proto.Event.BeamsConfig:type_name -> teleport.beams.v1.BeamsConfig
92, // [92:92] is the sub-list for method output_type
92, // [92:92] is the sub-list for method input_type
92, // [92:92] is the sub-list for extension type_name
92, // [92:92] is the sub-list for extension extendee
0, // [0:92] is the sub-list for field type_name
90, // 92: proto.Event.Classifier:type_name -> teleport.summarizer.v1.Classifier
93, // [93:93] is the sub-list for method output_type
93, // [93:93] is the sub-list for method input_type
93, // [93:93] is the sub-list for extension type_name
93, // [93:93] is the sub-list for extension extendee
0, // [0:93] is the sub-list for field type_name
}
func init() { file_teleport_legacy_client_proto_event_proto_init() }
@@ -4932,6 +4984,7 @@ func file_teleport_legacy_client_proto_event_proto_init() {
(*Event_Beam)(nil),
(*Event_ValidatedMFAChallengeV2)(nil),
(*Event_BeamsConfig)(nil),
(*Event_Classifier)(nil),
}
type x struct{}
out := protoimpl.TypeBuilder{
api/client/proto/event_protoopaque.pb.go
+59 -7
View File
@@ -975,6 +975,15 @@ func (x *Event) GetBeamsConfig() *v125.BeamsConfig {
return nil
}
func (x *Event) GetClassifier() *v124.Classifier {
if x != nil {
if x, ok := x.xxx_hidden_Resource.(*event_Classifier); ok {
return x.Classifier
}
}
return nil
}
func (x *Event) SetType(v Operation) {
x.xxx_hidden_Type = v
}
@@ -1708,6 +1717,14 @@ func (x *Event) SetBeamsConfig(v *v125.BeamsConfig) {
x.xxx_hidden_Resource = &event_BeamsConfig{v}
}
func (x *Event) SetClassifier(v *v124.Classifier) {
if v == nil {
x.xxx_hidden_Resource = nil
return
}
x.xxx_hidden_Resource = &event_Classifier{v}
}
func (x *Event) HasResource() bool {
if x == nil {
return false
@@ -2444,6 +2461,14 @@ func (x *Event) HasBeamsConfig() bool {
return ok
}
func (x *Event) HasClassifier() bool {
if x == nil {
return false
}
_, ok := x.xxx_hidden_Resource.(*event_Classifier)
return ok
}
func (x *Event) ClearResource() {
x.xxx_hidden_Resource = nil
}
@@ -2995,6 +3020,12 @@ func (x *Event) ClearBeamsConfig() {
}
}
func (x *Event) ClearClassifier() {
if _, ok := x.xxx_hidden_Resource.(*event_Classifier); ok {
x.xxx_hidden_Resource = nil
}
}
const Event_Resource_not_set_case case_Event_Resource = 0
const Event_ResourceHeader_case case_Event_Resource = 2
const Event_CertAuthority_case case_Event_Resource = 3
@@ -3087,6 +3118,7 @@ const Event_RetrievalModel_case case_Event_Resource = 94
const Event_Beam_case case_Event_Resource = 95
const Event_ValidatedMFAChallengeV2_case case_Event_Resource = 96
const Event_BeamsConfig_case case_Event_Resource = 97
const Event_Classifier_case case_Event_Resource = 98
func (x *Event) WhichResource() case_Event_Resource {
if x == nil {
@@ -3275,6 +3307,8 @@ func (x *Event) WhichResource() case_Event_Resource {
return Event_ValidatedMFAChallengeV2_case
case *event_BeamsConfig:
return Event_BeamsConfig_case
case *event_Classifier:
return Event_Classifier_case
default:
return Event_Resource_not_set_case
}
@@ -3477,6 +3511,8 @@ type Event_builder struct {
ValidatedMFAChallengeV2 *v21.ValidatedMFAChallenge
// BeamsConfig is the user-provided configuration for Beams.
BeamsConfig *v125.BeamsConfig
// Classifier is a resource for defining session summarization classifiers.
Classifier *v124.Classifier
// -- end of xxx_hidden_Resource
}
@@ -3758,6 +3794,9 @@ func (b0 Event_builder) Build() *Event {
if b.BeamsConfig != nil {
x.xxx_hidden_Resource = &event_BeamsConfig{b.BeamsConfig}
}
if b.Classifier != nil {
x.xxx_hidden_Resource = &event_Classifier{b.Classifier}
}
return m0
}
@@ -4237,6 +4276,11 @@ type event_BeamsConfig struct {
BeamsConfig *v125.BeamsConfig `protobuf:"bytes,97,opt,name=BeamsConfig,proto3,oneof"`
}
type event_Classifier struct {
// Classifier is a resource for defining session summarization classifiers.
Classifier *v124.Classifier `protobuf:"bytes,98,opt,name=Classifier,proto3,oneof"`
}
func (*event_ResourceHeader) isEvent_Resource() {}
func (*event_CertAuthority) isEvent_Resource() {}
@@ -4419,11 +4463,13 @@ func (*event_ValidatedMFAChallengeV2) isEvent_Resource() {}
func (*event_BeamsConfig) isEvent_Resource() {}
func (*event_Classifier) isEvent_Resource() {}
var File_teleport_legacy_client_proto_event_proto protoreflect.FileDescriptor
const file_teleport_legacy_client_proto_event_proto_rawDesc = "" +
"\n" +
"(teleport/legacy/client/proto/event.proto\x12\x05proto\x1a'teleport/accesslist/v1/accesslist.proto\x1a?teleport/accessmonitoringrules/v1/access_monitoring_rules.proto\x1a-teleport/appauthconfig/v1/appauthconfig.proto\x1a'teleport/autoupdate/v1/autoupdate.proto\x1a\x1cteleport/beams/v1/beam.proto\x1a$teleport/beams/v1/beams_config.proto\x1a5teleport/clusterconfig/v1/access_graph_settings.proto\x1a'teleport/crownjewel/v1/crownjewel.proto\x1a#teleport/dbobject/v1/dbobject.proto\x1a1teleport/discoveryconfig/v1/discoveryconfig.proto\x1a7teleport/healthcheckconfig/v1/health_check_config.proto\x1a/teleport/identitycenter/v1/identitycenter.proto\x1a;teleport/kubewaitingcontainer/v1/kubewaitingcontainer.proto\x1a!teleport/legacy/types/types.proto\x1a,teleport/linuxdesktop/v1/linux_desktop.proto\x1a(teleport/machineid/v1/bot_instance.proto\x1a&teleport/machineid/v1/federation.proto\x1a)teleport/mfa/v1/validated_challenge.proto\x1a)teleport/mfa/v2/validated_challenge.proto\x1a-teleport/notifications/v1/notifications.proto\x1a'teleport/presence/v1/relay_server.proto\x1a+teleport/provisioning/v1/provisioning.proto\x1a:teleport/recordingencryption/v1/recording_encryption.proto\x1a*teleport/scopes/access/v1/assignment.proto\x1a$teleport/scopes/access/v1/role.proto\x1a'teleport/secreports/v1/secreports.proto\x1a/teleport/subca/v1/cert_authority_override.proto\x1a'teleport/summarizer/v1/summarizer.proto\x1a/teleport/userloginstate/v1/userloginstate.proto\x1a1teleport/userprovisioning/v2/statichostuser.proto\x1a&teleport/usertasks/v1/user_tasks.proto\x1a+teleport/workloadidentity/v1/resource.proto\x1a6teleport/workloadidentity/v1/revocation_resource.proto\"\x858\n" +
"(teleport/legacy/client/proto/event.proto\x12\x05proto\x1a'teleport/accesslist/v1/accesslist.proto\x1a?teleport/accessmonitoringrules/v1/access_monitoring_rules.proto\x1a-teleport/appauthconfig/v1/appauthconfig.proto\x1a'teleport/autoupdate/v1/autoupdate.proto\x1a\x1cteleport/beams/v1/beam.proto\x1a$teleport/beams/v1/beams_config.proto\x1a5teleport/clusterconfig/v1/access_graph_settings.proto\x1a'teleport/crownjewel/v1/crownjewel.proto\x1a#teleport/dbobject/v1/dbobject.proto\x1a1teleport/discoveryconfig/v1/discoveryconfig.proto\x1a7teleport/healthcheckconfig/v1/health_check_config.proto\x1a/teleport/identitycenter/v1/identitycenter.proto\x1a;teleport/kubewaitingcontainer/v1/kubewaitingcontainer.proto\x1a!teleport/legacy/types/types.proto\x1a,teleport/linuxdesktop/v1/linux_desktop.proto\x1a(teleport/machineid/v1/bot_instance.proto\x1a&teleport/machineid/v1/federation.proto\x1a)teleport/mfa/v1/validated_challenge.proto\x1a)teleport/mfa/v2/validated_challenge.proto\x1a-teleport/notifications/v1/notifications.proto\x1a'teleport/presence/v1/relay_server.proto\x1a+teleport/provisioning/v1/provisioning.proto\x1a:teleport/recordingencryption/v1/recording_encryption.proto\x1a*teleport/scopes/access/v1/assignment.proto\x1a$teleport/scopes/access/v1/role.proto\x1a'teleport/secreports/v1/secreports.proto\x1a/teleport/subca/v1/cert_authority_override.proto\x1a'teleport/summarizer/v1/summarizer.proto\x1a/teleport/userloginstate/v1/userloginstate.proto\x1a1teleport/userprovisioning/v2/statichostuser.proto\x1a&teleport/usertasks/v1/user_tasks.proto\x1a+teleport/workloadidentity/v1/resource.proto\x1a6teleport/workloadidentity/v1/revocation_resource.proto\"\xcb8\n" +
"\x05Event\x12$\n" +
"\x04Type\x18\x01 \x01(\x0e2\x10.proto.OperationR\x04Type\x12?\n" +
"\x0eResourceHeader\x18\x02 \x01(\v2\x15.types.ResourceHeaderH\x00R\x0eResourceHeader\x12>\n" +
@@ -4529,7 +4575,10 @@ const file_teleport_legacy_client_proto_event_proto_rawDesc = "" +
"\x0eRetrievalModel\x18^ \x01(\v2&.teleport.summarizer.v1.RetrievalModelH\x00R\x0eRetrievalModel\x12-\n" +
"\x04Beam\x18_ \x01(\v2\x17.teleport.beams.v1.BeamH\x00R\x04Beam\x12b\n" +
"\x17ValidatedMFAChallengeV2\x18` \x01(\v2&.teleport.mfa.v2.ValidatedMFAChallengeH\x00R\x17ValidatedMFAChallengeV2\x12B\n" +
"\vBeamsConfig\x18a \x01(\v2\x1e.teleport.beams.v1.BeamsConfigH\x00R\vBeamsConfigB\n" +
"\vBeamsConfig\x18a \x01(\v2\x1e.teleport.beams.v1.BeamsConfigH\x00R\vBeamsConfig\x12D\n" +
"\n" +
"Classifier\x18b \x01(\v2\".teleport.summarizer.v1.ClassifierH\x00R\n" +
"ClassifierB\n" +
"\n" +
"\bResourceJ\x04\b\a\x10\bJ\x04\b1\x102J\x04\b?\x10@J\x04\bD\x10EJ\x04\bX\x10YR\x12ExternalCloudAuditR\x0eStaticHostUserR\x13AutoUpdateAgentPlanR\x0fWorkloadCluster**\n" +
"\tOperation\x12\b\n" +
@@ -4631,6 +4680,7 @@ var file_teleport_legacy_client_proto_event_proto_goTypes = []any{
(*v125.Beam)(nil), // 87: teleport.beams.v1.Beam
(*v21.ValidatedMFAChallenge)(nil), // 88: teleport.mfa.v2.ValidatedMFAChallenge
(*v125.BeamsConfig)(nil), // 89: teleport.beams.v1.BeamsConfig
(*v124.Classifier)(nil), // 90: teleport.summarizer.v1.Classifier
}
var file_teleport_legacy_client_proto_event_proto_depIdxs = []int32{
0, // 0: proto.Event.Type:type_name -> proto.Operation
@@ -4725,11 +4775,12 @@ var file_teleport_legacy_client_proto_event_proto_depIdxs = []int32{
87, // 89: proto.Event.Beam:type_name -> teleport.beams.v1.Beam
88, // 90: proto.Event.ValidatedMFAChallengeV2:type_name -> teleport.mfa.v2.ValidatedMFAChallenge
89, // 91: proto.Event.BeamsConfig:type_name -> teleport.beams.v1.BeamsConfig
92, // [92:92] is the sub-list for method output_type
92, // [92:92] is the sub-list for method input_type
92, // [92:92] is the sub-list for extension type_name
92, // [92:92] is the sub-list for extension extendee
0, // [0:92] is the sub-list for field type_name
90, // 92: proto.Event.Classifier:type_name -> teleport.summarizer.v1.Classifier
93, // [93:93] is the sub-list for method output_type
93, // [93:93] is the sub-list for method input_type
93, // [93:93] is the sub-list for extension type_name
93, // [93:93] is the sub-list for extension extendee
0, // [0:93] is the sub-list for field type_name
}
func init() { file_teleport_legacy_client_proto_event_proto_init() }
@@ -4829,6 +4880,7 @@ func file_teleport_legacy_client_proto_event_proto_init() {
(*event_Beam)(nil),
(*event_ValidatedMFAChallengeV2)(nil),
(*event_BeamsConfig)(nil),
(*event_Classifier)(nil),
}
type x struct{}
out := protoimpl.TypeBuilder{
api/gen/proto/go/teleport/summarizer/v1/summarizer_service.pb.go
+679 -207
View File
File diff suppressed because it is too large Load Diff
api/gen/proto/go/teleport/summarizer/v1/summarizer_service_grpc.pb.go
+120
View File
@@ -51,7 +51,10 @@ const (
SummarizerService_UpsertInferencePolicy_FullMethodName = "/teleport.summarizer.v1.SummarizerService/UpsertInferencePolicy"
SummarizerService_DeleteInferencePolicy_FullMethodName = "/teleport.summarizer.v1.SummarizerService/DeleteInferencePolicy"
SummarizerService_ListInferencePolicies_FullMethodName = "/teleport.summarizer.v1.SummarizerService/ListInferencePolicies"
SummarizerService_CreateClassifier_FullMethodName = "/teleport.summarizer.v1.SummarizerService/CreateClassifier"
SummarizerService_GetClassifier_FullMethodName = "/teleport.summarizer.v1.SummarizerService/GetClassifier"
SummarizerService_UpdateClassifier_FullMethodName = "/teleport.summarizer.v1.SummarizerService/UpdateClassifier"
SummarizerService_UpsertClassifier_FullMethodName = "/teleport.summarizer.v1.SummarizerService/UpsertClassifier"
SummarizerService_DeleteClassifier_FullMethodName = "/teleport.summarizer.v1.SummarizerService/DeleteClassifier"
SummarizerService_ListClassifiers_FullMethodName = "/teleport.summarizer.v1.SummarizerService/ListClassifiers"
SummarizerService_GetSummary_FullMethodName = "/teleport.summarizer.v1.SummarizerService/GetSummary"
@@ -113,8 +116,14 @@ type SummarizerServiceClient interface {
DeleteInferencePolicy(ctx context.Context, in *DeleteInferencePolicyRequest, opts ...grpc.CallOption) (*DeleteInferencePolicyResponse, error)
// ListInferencePolicies lists all InferencePolicies that match the request.
ListInferencePolicies(ctx context.Context, in *ListInferencePoliciesRequest, opts ...grpc.CallOption) (*ListInferencePoliciesResponse, error)
// CreateClassifier creates a new Classifier.
CreateClassifier(ctx context.Context, in *CreateClassifierRequest, opts ...grpc.CallOption) (*CreateClassifierResponse, error)
// GetClassifier retrieves an existing Classifier by name.
GetClassifier(ctx context.Context, in *GetClassifierRequest, opts ...grpc.CallOption) (*GetClassifierResponse, error)
// UpdateClassifier updates an existing Classifier.
UpdateClassifier(ctx context.Context, in *UpdateClassifierRequest, opts ...grpc.CallOption) (*UpdateClassifierResponse, error)
// UpsertClassifier creates a new Classifier or updates an existing one.
UpsertClassifier(ctx context.Context, in *UpsertClassifierRequest, opts ...grpc.CallOption) (*UpsertClassifierResponse, error)
// DeleteClassifier deletes an existing Classifier by name.
DeleteClassifier(ctx context.Context, in *DeleteClassifierRequest, opts ...grpc.CallOption) (*DeleteClassifierResponse, error)
// ListClassifiers lists all Classifiers that match the request.
@@ -338,6 +347,16 @@ func (c *summarizerServiceClient) ListInferencePolicies(ctx context.Context, in
return out, nil
}
func (c *summarizerServiceClient) CreateClassifier(ctx context.Context, in *CreateClassifierRequest, opts ...grpc.CallOption) (*CreateClassifierResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(CreateClassifierResponse)
err := c.cc.Invoke(ctx, SummarizerService_CreateClassifier_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *summarizerServiceClient) GetClassifier(ctx context.Context, in *GetClassifierRequest, opts ...grpc.CallOption) (*GetClassifierResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(GetClassifierResponse)
@@ -348,6 +367,26 @@ func (c *summarizerServiceClient) GetClassifier(ctx context.Context, in *GetClas
return out, nil
}
func (c *summarizerServiceClient) UpdateClassifier(ctx context.Context, in *UpdateClassifierRequest, opts ...grpc.CallOption) (*UpdateClassifierResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(UpdateClassifierResponse)
err := c.cc.Invoke(ctx, SummarizerService_UpdateClassifier_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *summarizerServiceClient) UpsertClassifier(ctx context.Context, in *UpsertClassifierRequest, opts ...grpc.CallOption) (*UpsertClassifierResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(UpsertClassifierResponse)
err := c.cc.Invoke(ctx, SummarizerService_UpsertClassifier_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *summarizerServiceClient) DeleteClassifier(ctx context.Context, in *DeleteClassifierRequest, opts ...grpc.CallOption) (*DeleteClassifierResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(DeleteClassifierResponse)
@@ -515,8 +554,14 @@ type SummarizerServiceServer interface {
DeleteInferencePolicy(context.Context, *DeleteInferencePolicyRequest) (*DeleteInferencePolicyResponse, error)
// ListInferencePolicies lists all InferencePolicies that match the request.
ListInferencePolicies(context.Context, *ListInferencePoliciesRequest) (*ListInferencePoliciesResponse, error)
// CreateClassifier creates a new Classifier.
CreateClassifier(context.Context, *CreateClassifierRequest) (*CreateClassifierResponse, error)
// GetClassifier retrieves an existing Classifier by name.
GetClassifier(context.Context, *GetClassifierRequest) (*GetClassifierResponse, error)
// UpdateClassifier updates an existing Classifier.
UpdateClassifier(context.Context, *UpdateClassifierRequest) (*UpdateClassifierResponse, error)
// UpsertClassifier creates a new Classifier or updates an existing one.
UpsertClassifier(context.Context, *UpsertClassifierRequest) (*UpsertClassifierResponse, error)
// DeleteClassifier deletes an existing Classifier by name.
DeleteClassifier(context.Context, *DeleteClassifierRequest) (*DeleteClassifierResponse, error)
// ListClassifiers lists all Classifiers that match the request.
@@ -614,9 +659,18 @@ func (UnimplementedSummarizerServiceServer) DeleteInferencePolicy(context.Contex
func (UnimplementedSummarizerServiceServer) ListInferencePolicies(context.Context, *ListInferencePoliciesRequest) (*ListInferencePoliciesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListInferencePolicies not implemented")
}
func (UnimplementedSummarizerServiceServer) CreateClassifier(context.Context, *CreateClassifierRequest) (*CreateClassifierResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateClassifier not implemented")
}
func (UnimplementedSummarizerServiceServer) GetClassifier(context.Context, *GetClassifierRequest) (*GetClassifierResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetClassifier not implemented")
}
func (UnimplementedSummarizerServiceServer) UpdateClassifier(context.Context, *UpdateClassifierRequest) (*UpdateClassifierResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpdateClassifier not implemented")
}
func (UnimplementedSummarizerServiceServer) UpsertClassifier(context.Context, *UpsertClassifierRequest) (*UpsertClassifierResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpsertClassifier not implemented")
}
func (UnimplementedSummarizerServiceServer) DeleteClassifier(context.Context, *DeleteClassifierRequest) (*DeleteClassifierResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteClassifier not implemented")
}
@@ -998,6 +1052,24 @@ func _SummarizerService_ListInferencePolicies_Handler(srv interface{}, ctx conte
return interceptor(ctx, in, info, handler)
}
func _SummarizerService_CreateClassifier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateClassifierRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SummarizerServiceServer).CreateClassifier(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: SummarizerService_CreateClassifier_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SummarizerServiceServer).CreateClassifier(ctx, req.(*CreateClassifierRequest))
}
return interceptor(ctx, in, info, handler)
}
func _SummarizerService_GetClassifier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetClassifierRequest)
if err := dec(in); err != nil {
@@ -1016,6 +1088,42 @@ func _SummarizerService_GetClassifier_Handler(srv interface{}, ctx context.Conte
return interceptor(ctx, in, info, handler)
}
func _SummarizerService_UpdateClassifier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateClassifierRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SummarizerServiceServer).UpdateClassifier(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: SummarizerService_UpdateClassifier_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SummarizerServiceServer).UpdateClassifier(ctx, req.(*UpdateClassifierRequest))
}
return interceptor(ctx, in, info, handler)
}
func _SummarizerService_UpsertClassifier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpsertClassifierRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SummarizerServiceServer).UpsertClassifier(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: SummarizerService_UpsertClassifier_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SummarizerServiceServer).UpsertClassifier(ctx, req.(*UpsertClassifierRequest))
}
return interceptor(ctx, in, info, handler)
}
func _SummarizerService_DeleteClassifier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteClassifierRequest)
if err := dec(in); err != nil {
@@ -1311,10 +1419,22 @@ var SummarizerService_ServiceDesc = grpc.ServiceDesc{
MethodName: "ListInferencePolicies",
Handler: _SummarizerService_ListInferencePolicies_Handler,
},
{
MethodName: "CreateClassifier",
Handler: _SummarizerService_CreateClassifier_Handler,
},
{
MethodName: "GetClassifier",
Handler: _SummarizerService_GetClassifier_Handler,
},
{
MethodName: "UpdateClassifier",
Handler: _SummarizerService_UpdateClassifier_Handler,
},
{
MethodName: "UpsertClassifier",
Handler: _SummarizerService_UpsertClassifier_Handler,
},
{
MethodName: "DeleteClassifier",
Handler: _SummarizerService_DeleteClassifier_Handler,
api/gen/proto/go/teleport/summarizer/v1/summarizer_service_protoopaque.pb.go
+673 -207
View File
File diff suppressed because it is too large Load Diff
api/proto/teleport/legacy/client/proto/event.proto
+2
View File
@@ -266,5 +266,7 @@ message Event {
teleport.mfa.v2.ValidatedMFAChallenge ValidatedMFAChallengeV2 = 96;
// BeamsConfig is the user-provided configuration for Beams.
teleport.beams.v1.BeamsConfig BeamsConfig = 97;
// Classifier is a resource for defining session summarization classifiers.
teleport.summarizer.v1.Classifier Classifier = 98;
}
}
api/proto/teleport/summarizer/v1/summarizer_service.proto
+43
View File
@@ -66,8 +66,14 @@ service SummarizerService {
// ListInferencePolicies lists all InferencePolicies that match the request.
rpc ListInferencePolicies(ListInferencePoliciesRequest) returns (ListInferencePoliciesResponse);
// CreateClassifier creates a new Classifier.
rpc CreateClassifier(CreateClassifierRequest) returns (CreateClassifierResponse);
// GetClassifier retrieves an existing Classifier by name.
rpc GetClassifier(GetClassifierRequest) returns (GetClassifierResponse);
// UpdateClassifier updates an existing Classifier.
rpc UpdateClassifier(UpdateClassifierRequest) returns (UpdateClassifierResponse);
// UpsertClassifier creates a new Classifier or updates an existing one.
rpc UpsertClassifier(UpsertClassifierRequest) returns (UpsertClassifierResponse);
// DeleteClassifier deletes an existing Classifier by name.
rpc DeleteClassifier(DeleteClassifierRequest) returns (DeleteClassifierResponse);
// ListClassifiers lists all Classifiers that match the request.
@@ -353,6 +359,18 @@ message ListInferencePoliciesResponse {
// Summarization classifiers
// CreateClassifierRequest is a request for creating a Classifier.
message CreateClassifierRequest {
// Classifier is the Classifier resource to create.
Classifier classifier = 1;
}
// CreateClassifierResponse is a response to creating a Classifier.
message CreateClassifierResponse {
// Classifier is the Classifier resource that was created.
Classifier classifier = 1;
}
// GetClassifierRequest is a request for retrieving a Classifier.
message GetClassifierRequest {
// Name is the resource name of the Classifier to retrieve.
@@ -365,6 +383,31 @@ message GetClassifierResponse {
Classifier classifier = 1;
}
// UpdateClassifierRequest is a request for updating a Classifier.
message UpdateClassifierRequest {
// Classifier is the Classifier resource to update.
Classifier classifier = 1;
}
// UpdateClassifierResponse is a response to updating a Classifier.
message UpdateClassifierResponse {
// Classifier is the Classifier resource that was updated.
Classifier classifier = 1;
}
// UpsertClassifierRequest is a request for creating or updating a Classifier.
message UpsertClassifierRequest {
// Classifier is the Classifier resource to create or update.
Classifier classifier = 1;
}
// UpsertClassifierResponse is a response to creating or updating a
// Classifier.
message UpsertClassifierResponse {
// Classifier is the Classifier resource that was created or updated.
Classifier classifier = 1;
}
// DeleteClassifierRequest is a request for deleting a Classifier.
message DeleteClassifierRequest {
// Name is the resource name of the Classifier to delete.