From cbffdca9830feecdf8d7984e474abcc30f544fd4 Mon Sep 17 00:00:00 2001 From: oleksandr-codefresh Date: Thu, 15 Aug 2024 12:12:31 +0300 Subject: [PATCH] re-generated files --- assets/swagger.json | 61 ----- .../notifications/services/opsgenie.md | 48 +++- pkg/apiclient/events/events.pb.go | 237 +++++------------- 3 files changed, 103 insertions(+), 243 deletions(-) diff --git a/assets/swagger.json b/assets/swagger.json index 1e467c4aa18bc..3d1d39da23a2c 100644 --- a/assets/swagger.json +++ b/assets/swagger.json @@ -4056,52 +4056,6 @@ } } }, - "/api/v1/stream/events": { - "get": { - "tags": [ - "Eventing" - ], - "operationId": "Eventing_StartEventSource", - "parameters": [ - { - "type": "string", - "description": "The event source name.", - "name": "name", - "in": "query" - }, - { - "type": "string", - "format": "byte", - "description": "The event source configuration value.", - "name": "config", - "in": "query" - } - ], - "responses": { - "200": { - "description": "A successful response.(streaming responses)", - "schema": { - "type": "object", - "title": "Stream result of genericEvent", - "properties": { - "error": { - "$ref": "#/definitions/runtimeStreamError" - }, - "result": { - "$ref": "#/definitions/genericEvent" - } - } - } - }, - "default": { - "description": "An unexpected error response.", - "schema": { - "$ref": "#/definitions/runtimeError" - } - } - } - } - }, "/api/version": { "get": { "tags": [ @@ -4790,21 +4744,6 @@ } } }, - "genericEvent": { - "type": "object", - "title": "*\nRepresents an event", - "properties": { - "name": { - "description": "The event source name.", - "type": "string" - }, - "payload": { - "description": "The event payload.", - "type": "string", - "format": "byte" - } - } - }, "gpgkeyGnuPGPublicKeyCreateResponse": { "type": "object", "title": "Response to a public key creation request", diff --git a/docs/operator-manual/notifications/services/opsgenie.md b/docs/operator-manual/notifications/services/opsgenie.md index c590a4ac979b6..2cc1ebff62abf 100755 --- a/docs/operator-manual/notifications/services/opsgenie.md +++ b/docs/operator-manual/notifications/services/opsgenie.md @@ -7,22 +7,58 @@ To be able to send notifications with argocd-notifications you have to create an 3. Click "Teams" in the Menu on the left 4. Select the team that you want to notify 5. In the teams configuration menu select "Integrations" -6. click "Add Integration" in the top right corner +6. Click "Add Integration" in the top right corner 7. Select "API" integration 8. Give your integration a name, copy the "API key" and safe it somewhere for later -9. Make sure the checkboxes for "Create and Update Access" and "enable" are selected, disable the other checkboxes to remove unnecessary permissions -10. Click "Safe Integration" at the bottom -11. Check your browser for the correct server apiURL. If it is "app.opsgenie.com" then use the US/international api url `api.opsgenie.com` in the next step, otherwise use `api.eu.opsgenie.com` (European API). -12. You are finished with configuring opsgenie. Now you need to configure argocd-notifications. Use the apiUrl, the team name and the apiKey to configure the Opsgenie integration in the `argocd-notifications-secret` secret. +9. Click "Edit" in the integration settings +10. Make sure the checkbox for "Create and Update Access" is selected, disable the other checkboxes to remove unnecessary permissions +11. Click "Save" at the bottom +12. Click "Turn on integration" in the top right corner +13. Check your browser for the correct server apiURL. If it is "app.opsgenie.com" then use the US/international api url `api.opsgenie.com` in the next step, otherwise use `api.eu.opsgenie.com` (European API). +14. You are finished with configuring Opsgenie. Now you need to configure argocd-notifications. Use the apiUrl, the team name and the apiKey to configure the Opsgenie integration in the `argocd-notifications-secret` secret. +15. You can find the example `argocd-notifications-cm` configuration at the below. + +| **Option** | **Required** | **Type** | **Description** | **Example** | +| ------------- | ------------ | -------- | -------------------------------------------------------------------------------------------------------- | -------------------------------- | +| `description` | True | `string` | Description field of the alert that is generally used to provide a detailed information about the alert. | `Hello from Argo CD!` | +| `priority` | False | `string` | Priority level of the alert. Possible values are P1, P2, P3, P4 and P5. Default value is P3. | `P1` | +| `alias` | False | `string` | Client-defined identifier of the alert, that is also the key element of Alert De-Duplication. | `Life is too short for no alias` | +| `note` | False | `string` | Additional note that will be added while creating the alert. | `Error from Argo CD!` | ```yaml apiVersion: v1 kind: ConfigMap metadata: - name: + name: argocd-notifications-cm data: service.opsgenie: | apiUrl: apiKeys: : + template.opsgenie: | + message: | + [Argo CD] Application {{.app.metadata.name}} has a problem. + opsgenie: + description: | + Application: {{.app.metadata.name}} + Health Status: {{.app.status.health.status}} + Operation State Phase: {{.app.status.operationState.phase}} + Sync Status: {{.app.status.sync.status}} + priority: P1 + alias: {{.app.metadata.name}} + note: Error from Argo CD! + trigger.on-a-problem: | + - description: Application has a problem. + send: + - opsgenie + when: app.status.health.status == 'Degraded' or app.status.operationState.phase in ['Error', 'Failed'] or app.status.sync.status == 'Unknown' +``` + +16. Add annotation in application yaml file to enable notifications for specific Argo CD app. +```yaml + apiVersion: argoproj.io/v1alpha1 + kind: Application + metadata: + annotations: + notifications.argoproj.io/subscribe.on-a-problem.opsgenie: ``` \ No newline at end of file diff --git a/pkg/apiclient/events/events.pb.go b/pkg/apiclient/events/events.pb.go index 5f19438b95c2f..d00ffe18cc196 100644 --- a/pkg/apiclient/events/events.pb.go +++ b/pkg/apiclient/events/events.pb.go @@ -9,16 +9,12 @@ package events import ( - context "context" fmt "fmt" _ "github.com/argoproj/argo-cd/v2/pkg/apis/application/v1alpha1" _ "github.com/gogo/protobuf/gogoproto" github_com_gogo_protobuf_proto "github.com/gogo/protobuf/proto" proto "github.com/gogo/protobuf/proto" _ "google.golang.org/genproto/googleapis/api/annotations" - grpc "google.golang.org/grpc" - codes "google.golang.org/grpc/codes" - status "google.golang.org/grpc/status" io "io" v1 "k8s.io/apimachinery/pkg/apis/meta/v1" math "math" @@ -674,178 +670,67 @@ func init() { func init() { proto.RegisterFile("server/application/events.proto", fileDescriptor_3ad9267ec62b112f) } var fileDescriptor_3ad9267ec62b112f = []byte{ - // 1009 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x56, 0xdd, 0x6e, 0x1c, 0xb5, - 0x17, 0xff, 0xcf, 0xe6, 0xfb, 0xec, 0x26, 0xed, 0xdf, 0x49, 0x5a, 0x2b, 0x0a, 0xe9, 0x6a, 0x15, - 0xa1, 0x55, 0xd5, 0xce, 0x92, 0xf0, 0xa1, 0xb6, 0x42, 0x48, 0xa9, 0x12, 0x44, 0x20, 0x01, 0x34, - 0xa1, 0x95, 0xe8, 0x9d, 0x33, 0x73, 0x3a, 0xeb, 0xee, 0x8c, 0x6d, 0x6c, 0xef, 0x4a, 0x7b, 0x8b, - 0x78, 0x03, 0x9e, 0x84, 0xb7, 0xe8, 0x25, 0x12, 0xf7, 0x08, 0x45, 0x48, 0xbc, 0x06, 0xb2, 0x67, - 0x76, 0xe3, 0x09, 0xb9, 0xa0, 0xdc, 0xf9, 0xfc, 0xce, 0xef, 0x1c, 0xfb, 0xcc, 0xf9, 0x1a, 0x78, - 0x60, 0x50, 0x4f, 0x50, 0x0f, 0x98, 0x52, 0x05, 0x4f, 0x99, 0xe5, 0x52, 0x0c, 0x70, 0x82, 0xc2, - 0x9a, 0x58, 0x69, 0x69, 0x25, 0x59, 0xc9, 0x51, 0xa0, 0xe6, 0xe9, 0xce, 0x59, 0xce, 0xed, 0x70, - 0x7c, 0x19, 0xa7, 0xb2, 0x1c, 0x30, 0x9d, 0x4b, 0xa5, 0xe5, 0x1b, 0x7f, 0x78, 0x9c, 0x66, 0x83, - 0xc9, 0xe1, 0x40, 0x8d, 0xf2, 0x01, 0x53, 0xdc, 0x34, 0x5c, 0x4d, 0x0e, 0x58, 0xa1, 0x86, 0xec, - 0x60, 0xe0, 0xbd, 0x30, 0x8b, 0x59, 0xe5, 0x76, 0xe7, 0xa3, 0xd1, 0x13, 0x13, 0x73, 0xe9, 0x2c, - 0x4a, 0x96, 0x0e, 0xb9, 0x40, 0x3d, 0xbd, 0x76, 0x51, 0xa2, 0x65, 0x83, 0xc9, 0x3f, 0xad, 0xb6, - 0x72, 0xe9, 0x2f, 0xb6, 0x72, 0xe0, 0x4e, 0x35, 0xba, 0x9b, 0x4b, 0x99, 0x17, 0xe8, 0x4c, 0x07, - 0x4c, 0x08, 0x69, 0xfd, 0xdd, 0x75, 0x00, 0xbd, 0xa7, 0xd0, 0x3e, 0x71, 0x01, 0x5d, 0xc8, 0xb1, - 0x4e, 0x91, 0x10, 0x58, 0x14, 0xac, 0x44, 0x1a, 0x75, 0x5b, 0xfd, 0xb5, 0xc4, 0x9f, 0xc9, 0x3d, - 0x58, 0x4e, 0xa5, 0x78, 0xcd, 0x73, 0xda, 0xea, 0x46, 0xfd, 0x4e, 0x52, 0x4b, 0xbd, 0x8f, 0x61, - 0xc9, 0x9b, 0xde, 0x6a, 0x44, 0x61, 0x45, 0xb1, 0x69, 0x21, 0x59, 0x46, 0x5b, 0xdd, 0x56, 0xbf, - 0x93, 0xcc, 0xc4, 0xde, 0x5f, 0x11, 0x74, 0xbc, 0xdd, 0xb7, 0x15, 0x40, 0x7a, 0xb0, 0x66, 0x79, - 0x89, 0xc6, 0xb2, 0x52, 0x55, 0x3e, 0x9e, 0x2f, 0xbe, 0xfd, 0xfd, 0xc1, 0xff, 0x92, 0x6b, 0xd8, - 0xbd, 0x41, 0x5e, 0xbe, 0xc1, 0xd4, 0xd6, 0xde, 0x6a, 0x89, 0x3c, 0x86, 0x65, 0xe3, 0x5f, 0x4e, - 0x17, 0xba, 0xad, 0x7e, 0xfb, 0x70, 0x3b, 0xae, 0x13, 0x12, 0x7f, 0xe3, 0x09, 0x55, 0x58, 0x49, - 0x4d, 0x22, 0x8f, 0x60, 0x19, 0xb5, 0x96, 0xda, 0xd0, 0xc5, 0xee, 0x42, 0xbf, 0x7d, 0xb8, 0x75, - 0x83, 0x7e, 0xe2, 0x94, 0x49, 0xcd, 0x21, 0x9f, 0x41, 0x9b, 0x29, 0xf5, 0x12, 0xb5, 0x71, 0x1f, - 0x8c, 0x2e, 0x75, 0xa3, 0x7e, 0xfb, 0x70, 0x77, 0x6e, 0x72, 0x74, 0x9d, 0xc9, 0x19, 0x27, 0x09, - 0x0d, 0x7a, 0x3f, 0xad, 0x41, 0x27, 0x7c, 0x06, 0x89, 0xe1, 0x4e, 0x86, 0x86, 0x6b, 0xcc, 0xce, - 0x99, 0xe0, 0xaf, 0xd1, 0x58, 0x1a, 0x75, 0xa3, 0x79, 0xbc, 0x37, 0x95, 0xe4, 0x11, 0x6c, 0xb0, - 0xd4, 0x8e, 0x59, 0x31, 0xa7, 0xb7, 0x02, 0xfa, 0x0d, 0x1d, 0x79, 0x1f, 0xda, 0x39, 0xb7, 0x73, - 0xea, 0x42, 0x40, 0x0d, 0x15, 0x64, 0x0f, 0x56, 0x34, 0x2a, 0xf9, 0x22, 0x39, 0xa3, 0x8b, 0x01, - 0x67, 0x06, 0x12, 0x0a, 0x8b, 0x8a, 0xd9, 0xa1, 0x8f, 0x77, 0xa6, 0xf4, 0x08, 0xe9, 0xc2, 0xaa, - 0xc6, 0x09, 0x77, 0xd1, 0xd1, 0xe5, 0x40, 0x3b, 0x47, 0xc9, 0x43, 0x58, 0x4f, 0x65, 0x59, 0x72, - 0x7b, 0x8e, 0xc6, 0xb0, 0x1c, 0xe9, 0x4a, 0x40, 0x6b, 0xaa, 0x48, 0x1f, 0x3a, 0x15, 0x70, 0x34, - 0xb6, 0x43, 0xa9, 0xe9, 0x6a, 0x40, 0x6d, 0x68, 0xc8, 0x97, 0x00, 0x95, 0x7c, 0xcc, 0x2c, 0xd2, - 0x35, 0x9f, 0x87, 0x87, 0x71, 0xd5, 0x23, 0x71, 0xd8, 0x23, 0xb1, 0x1a, 0xe5, 0x0e, 0x30, 0xb1, - 0xeb, 0x91, 0x78, 0x72, 0x10, 0x7f, 0xc7, 0x4b, 0x4c, 0x02, 0x6b, 0x17, 0x3d, 0x53, 0xea, 0x6b, - 0x57, 0xaf, 0x10, 0x46, 0x5f, 0x83, 0xe4, 0x0b, 0x58, 0x63, 0x4a, 0x9d, 0xb1, 0x4b, 0x2c, 0x0c, - 0x6d, 0xfb, 0x2a, 0xd9, 0xbf, 0xb5, 0xa8, 0x5c, 0xfe, 0x2b, 0xda, 0x89, 0xb0, 0x7a, 0x3a, 0xab, - 0xd9, 0xb9, 0x31, 0xd9, 0x07, 0x30, 0x53, 0x91, 0x5e, 0x58, 0x66, 0xc7, 0x86, 0x76, 0x82, 0xcb, - 0x02, 0x9c, 0xbc, 0x84, 0xf5, 0x5a, 0xd2, 0x16, 0xb3, 0x23, 0x4b, 0xd7, 0xdf, 0x35, 0xbc, 0xd9, - 0xd7, 0x6d, 0xb8, 0x21, 0x09, 0x6c, 0x38, 0xe0, 0x73, 0x2e, 0xb8, 0x19, 0x7a, 0xc7, 0x1b, 0xef, - 0xfc, 0xdd, 0x6e, 0x78, 0x20, 0x3d, 0xe8, 0x0c, 0x91, 0x15, 0x76, 0x58, 0xc7, 0x74, 0xc7, 0xc5, - 0x94, 0x34, 0x30, 0xb2, 0x0f, 0xeb, 0x95, 0x3c, 0xab, 0x80, 0xbb, 0x9e, 0xd4, 0x04, 0x5d, 0x16, - 0xd2, 0x62, 0x6c, 0x2c, 0x6a, 0xfa, 0xff, 0x30, 0x0b, 0x35, 0xe8, 0x66, 0xc2, 0x90, 0x1b, 0x2b, - 0xf5, 0xf4, 0x34, 0xa3, 0xa4, 0x1b, 0xf5, 0x17, 0x66, 0xdf, 0x77, 0x0e, 0x93, 0x67, 0xb0, 0x2d, - 0x95, 0x1b, 0x80, 0x5c, 0x8a, 0x8b, 0xa9, 0x48, 0x93, 0x59, 0x69, 0x6e, 0x06, 0x1e, 0x6f, 0xa7, - 0x90, 0x5d, 0x58, 0x66, 0x4a, 0xbd, 0x38, 0x3d, 0xa6, 0x5b, 0x01, 0xb9, 0xc6, 0x5c, 0x65, 0xd6, - 0xe5, 0x60, 0x14, 0x4b, 0x91, 0x6e, 0x87, 0x95, 0x19, 0x6a, 0xc8, 0x27, 0xb0, 0xc9, 0x94, 0x3a, - 0x15, 0xc6, 0x32, 0x91, 0xa2, 0x4f, 0xfc, 0x57, 0x38, 0xa5, 0xf7, 0x02, 0x83, 0xdb, 0x08, 0xae, - 0xb3, 0xad, 0x66, 0xe9, 0x88, 0x8b, 0xfc, 0x1c, 0xed, 0x50, 0x66, 0xf4, 0x7e, 0xd8, 0xd9, 0x4d, - 0xdd, 0xce, 0xa7, 0xb0, 0xd1, 0x2c, 0x36, 0x72, 0x17, 0x16, 0x46, 0x38, 0xad, 0xa6, 0x47, 0xe2, - 0x8e, 0x64, 0x0b, 0x96, 0x26, 0xac, 0x18, 0x63, 0x35, 0x22, 0x92, 0x4a, 0x78, 0xd6, 0x7a, 0x12, - 0xf5, 0x7e, 0x89, 0xa0, 0x1d, 0x8c, 0x37, 0xd7, 0xdf, 0x76, 0xaa, 0xb0, 0x31, 0x7a, 0x3c, 0x42, - 0x76, 0x60, 0xa9, 0xc0, 0x09, 0x16, 0x8d, 0x31, 0x53, 0x41, 0x2e, 0x63, 0x65, 0x9d, 0xd1, 0x70, - 0xb2, 0xcc, 0x40, 0x72, 0x06, 0xab, 0x05, 0x33, 0xf6, 0x02, 0x51, 0xf8, 0xb1, 0xf2, 0x5f, 0x4a, - 0x78, 0xee, 0xa1, 0xf7, 0x0a, 0x3a, 0xc7, 0xa8, 0x50, 0x64, 0x28, 0x52, 0x8e, 0xc6, 0xad, 0x98, - 0x42, 0xa6, 0xa3, 0x3a, 0x60, 0x7f, 0x76, 0x58, 0x86, 0xca, 0xd4, 0x01, 0xfb, 0xb3, 0xab, 0x50, - 0x8d, 0x3f, 0x8c, 0xb9, 0xc6, 0xd2, 0x6d, 0xe9, 0xea, 0xa9, 0x49, 0x03, 0xeb, 0x29, 0xd8, 0xbc, - 0x65, 0x74, 0x93, 0x3d, 0x80, 0xeb, 0xe1, 0x5d, 0x5f, 0x14, 0x20, 0xe4, 0x29, 0x74, 0xb2, 0xe0, - 0x49, 0xfe, 0xda, 0x70, 0xe1, 0x84, 0xef, 0x4d, 0x1a, 0xd4, 0x43, 0x84, 0x55, 0xbf, 0xf1, 0xb8, - 0xc8, 0xc9, 0xf7, 0x70, 0xd7, 0x37, 0x69, 0xb8, 0x75, 0xaf, 0xd7, 0x50, 0x80, 0xee, 0x6c, 0x34, - 0xd1, 0xde, 0x7b, 0x3f, 0xfe, 0xf6, 0xe7, 0xcf, 0xad, 0xfb, 0x64, 0xdb, 0xaf, 0xf2, 0xc9, 0xc1, - 0xc0, 0x58, 0x8d, 0xac, 0xac, 0x7f, 0x48, 0x3e, 0x88, 0x9e, 0x1f, 0xbd, 0xbd, 0xda, 0x8b, 0x7e, - 0xbd, 0xda, 0x8b, 0xfe, 0xb8, 0xda, 0x8b, 0x5e, 0x7d, 0xf8, 0xef, 0xfe, 0x48, 0xd2, 0x82, 0xa3, - 0xb0, 0xb5, 0x93, 0xbf, 0x03, 0x00, 0x00, 0xff, 0xff, 0xc3, 0x5b, 0xa5, 0x9e, 0xf1, 0x08, 0x00, - 0x00, -} - -// Reference imports to suppress errors if they are not otherwise used. -var _ context.Context -var _ grpc.ClientConn - -// This is a compile-time assertion to ensure that this generated file -// is compatible with the grpc package it is being compiled against. -const _ = grpc.SupportPackageIsVersion4 - -// EventingClient is the client API for Eventing service. -// -// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. -type EventingClient interface { - StartEventSource(ctx context.Context, in *EventSource, opts ...grpc.CallOption) (Eventing_StartEventSourceClient, error) -} - -type eventingClient struct { - cc *grpc.ClientConn -} - -func NewEventingClient(cc *grpc.ClientConn) EventingClient { - return &eventingClient{cc} -} - -func (c *eventingClient) StartEventSource(ctx context.Context, in *EventSource, opts ...grpc.CallOption) (Eventing_StartEventSourceClient, error) { - stream, err := c.cc.NewStream(ctx, &_Eventing_serviceDesc.Streams[0], "/generic.Eventing/StartEventSource", opts...) - if err != nil { - return nil, err - } - x := &eventingStartEventSourceClient{stream} - if err := x.ClientStream.SendMsg(in); err != nil { - return nil, err - } - if err := x.ClientStream.CloseSend(); err != nil { - return nil, err - } - return x, nil -} - -type Eventing_StartEventSourceClient interface { - Recv() (*Event, error) - grpc.ClientStream -} - -type eventingStartEventSourceClient struct { - grpc.ClientStream -} - -func (x *eventingStartEventSourceClient) Recv() (*Event, error) { - m := new(Event) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} - -// EventingServer is the server API for Eventing service. -type EventingServer interface { - StartEventSource(*EventSource, Eventing_StartEventSourceServer) error -} - -// UnimplementedEventingServer can be embedded to have forward compatible implementations. -type UnimplementedEventingServer struct { -} - -func (*UnimplementedEventingServer) StartEventSource(req *EventSource, srv Eventing_StartEventSourceServer) error { - return status.Errorf(codes.Unimplemented, "method StartEventSource not implemented") -} - -func RegisterEventingServer(s *grpc.Server, srv EventingServer) { - s.RegisterService(&_Eventing_serviceDesc, srv) -} - -func _Eventing_StartEventSource_Handler(srv interface{}, stream grpc.ServerStream) error { - m := new(EventSource) - if err := stream.RecvMsg(m); err != nil { - return err - } - return srv.(EventingServer).StartEventSource(m, &eventingStartEventSourceServer{stream}) -} - -type Eventing_StartEventSourceServer interface { - Send(*Event) error - grpc.ServerStream -} - -type eventingStartEventSourceServer struct { - grpc.ServerStream -} - -func (x *eventingStartEventSourceServer) Send(m *Event) error { - return x.ServerStream.SendMsg(m) -} - -var _Eventing_serviceDesc = grpc.ServiceDesc{ - ServiceName: "generic.Eventing", - HandlerType: (*EventingServer)(nil), - Methods: []grpc.MethodDesc{}, - Streams: []grpc.StreamDesc{ - { - StreamName: "StartEventSource", - Handler: _Eventing_StartEventSource_Handler, - ServerStreams: true, - }, - }, - Metadata: "server/application/events.proto", + // 958 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x56, 0xcf, 0x6e, 0xdc, 0xb6, + 0x13, 0xfe, 0x69, 0xfd, 0x7f, 0x76, 0xed, 0xe4, 0x47, 0xdb, 0x29, 0x61, 0x18, 0xce, 0x62, 0x61, + 0x14, 0x8b, 0x20, 0xd1, 0xc2, 0xee, 0x1f, 0x24, 0x41, 0x51, 0xc0, 0x81, 0x5d, 0xd4, 0xad, 0xdd, + 0x16, 0x72, 0x93, 0x43, 0x6e, 0xb4, 0x34, 0xd1, 0x32, 0x2b, 0x91, 0x2c, 0xc9, 0x5d, 0x60, 0xef, + 0x7d, 0xa1, 0xbe, 0x45, 0x8e, 0x7d, 0x82, 0xa2, 0xf0, 0xa5, 0xaf, 0x51, 0x90, 0x92, 0xd6, 0x94, + 0xeb, 0x43, 0xd3, 0x1b, 0xe7, 0x9b, 0x6f, 0x86, 0xfc, 0x38, 0xc3, 0x91, 0xe0, 0xb1, 0x41, 0x3d, + 0x43, 0x3d, 0x62, 0x4a, 0x15, 0x3c, 0x65, 0x96, 0x4b, 0x31, 0xc2, 0x19, 0x0a, 0x6b, 0x62, 0xa5, + 0xa5, 0x95, 0x64, 0x2d, 0x47, 0x81, 0x9a, 0xa7, 0x7b, 0x17, 0x39, 0xb7, 0xe3, 0xe9, 0x75, 0x9c, + 0xca, 0x72, 0xc4, 0x74, 0x2e, 0x95, 0x96, 0xef, 0xfd, 0xe2, 0x59, 0x9a, 0x8d, 0x66, 0xc7, 0x23, + 0x35, 0xc9, 0x47, 0x4c, 0x71, 0xd3, 0x4a, 0x35, 0x3b, 0x62, 0x85, 0x1a, 0xb3, 0xa3, 0x91, 0xcf, + 0xc2, 0x2c, 0x66, 0x55, 0xda, 0xbd, 0xcf, 0x27, 0xcf, 0x4d, 0xcc, 0xa5, 0x8b, 0x28, 0x59, 0x3a, + 0xe6, 0x02, 0xf5, 0xfc, 0x36, 0x45, 0x89, 0x96, 0x8d, 0x66, 0xff, 0x8c, 0xda, 0xc9, 0xa5, 0xdf, + 0xd8, 0xca, 0x91, 0x5b, 0xd5, 0xe8, 0x7e, 0x2e, 0x65, 0x5e, 0xa0, 0x0b, 0x1d, 0x31, 0x21, 0xa4, + 0xf5, 0x7b, 0xd7, 0x02, 0x06, 0x2f, 0xa0, 0x7b, 0xe6, 0x04, 0x5d, 0xc9, 0xa9, 0x4e, 0x91, 0x10, + 0x58, 0x16, 0xac, 0x44, 0x1a, 0xf5, 0x3b, 0xc3, 0x8d, 0xc4, 0xaf, 0xc9, 0x23, 0x58, 0x4d, 0xa5, + 0x78, 0xc7, 0x73, 0xda, 0xe9, 0x47, 0xc3, 0x5e, 0x52, 0x5b, 0x83, 0x2f, 0x60, 0xc5, 0x87, 0xde, + 0x1b, 0x44, 0x61, 0x4d, 0xb1, 0x79, 0x21, 0x59, 0x46, 0x3b, 0xfd, 0xce, 0xb0, 0x97, 0x34, 0xe6, + 0xe0, 0xaf, 0x08, 0x7a, 0x3e, 0xee, 0xa7, 0x0a, 0x20, 0x03, 0xd8, 0xb0, 0xbc, 0x44, 0x63, 0x59, + 0xa9, 0xaa, 0x1c, 0xaf, 0x96, 0x3f, 0xfc, 0xf1, 0xf8, 0x7f, 0xc9, 0x2d, 0xec, 0xce, 0x20, 0xaf, + 0xdf, 0x63, 0x6a, 0xeb, 0x6c, 0xb5, 0x45, 0x9e, 0xc1, 0xaa, 0xf1, 0x27, 0xa7, 0x4b, 0xfd, 0xce, + 0xb0, 0x7b, 0xbc, 0x1b, 0xd7, 0x05, 0x89, 0x7f, 0xf4, 0x84, 0x4a, 0x56, 0x52, 0x93, 0xc8, 0x53, + 0x58, 0x45, 0xad, 0xa5, 0x36, 0x74, 0xb9, 0xbf, 0x34, 0xec, 0x1e, 0xef, 0xdc, 0xa1, 0x9f, 0x39, + 0x67, 0x52, 0x73, 0xc8, 0xd7, 0xd0, 0x65, 0x4a, 0xbd, 0x41, 0x6d, 0xdc, 0x85, 0xd1, 0x95, 0x7e, + 0x34, 0xec, 0x1e, 0xef, 0x2f, 0x42, 0x4e, 0x6e, 0x2b, 0xd9, 0x70, 0x92, 0x30, 0x60, 0xf0, 0xeb, + 0x06, 0xf4, 0xc2, 0x63, 0x90, 0x18, 0x1e, 0x64, 0x68, 0xb8, 0xc6, 0xec, 0x92, 0x09, 0xfe, 0x0e, + 0x8d, 0xa5, 0x51, 0x3f, 0x5a, 0xe8, 0xbd, 0xeb, 0x24, 0x4f, 0x61, 0x8b, 0xa5, 0x76, 0xca, 0x8a, + 0x05, 0xbd, 0x13, 0xd0, 0xef, 0xf8, 0xc8, 0xa7, 0xd0, 0xcd, 0xb9, 0x5d, 0x50, 0x97, 0x02, 0x6a, + 0xe8, 0x20, 0x07, 0xb0, 0xa6, 0x51, 0xc9, 0xd7, 0xc9, 0x05, 0x5d, 0x0e, 0x38, 0x0d, 0x48, 0x28, + 0x2c, 0x2b, 0x66, 0xc7, 0x5e, 0x6f, 0xe3, 0xf4, 0x08, 0xe9, 0xc3, 0xba, 0xc6, 0x19, 0x77, 0xea, + 0xe8, 0x6a, 0xe0, 0x5d, 0xa0, 0xe4, 0x09, 0x6c, 0xa6, 0xb2, 0x2c, 0xb9, 0xbd, 0x44, 0x63, 0x58, + 0x8e, 0x74, 0x2d, 0xa0, 0xb5, 0x5d, 0x64, 0x08, 0xbd, 0x0a, 0x38, 0x99, 0xda, 0xb1, 0xd4, 0x74, + 0x3d, 0xa0, 0xb6, 0x3c, 0xe4, 0x3b, 0x80, 0xca, 0x3e, 0x65, 0x16, 0xe9, 0x86, 0xaf, 0xc3, 0x93, + 0xb8, 0x7a, 0x23, 0x71, 0xf8, 0x46, 0x62, 0x35, 0xc9, 0x1d, 0x60, 0x62, 0xf7, 0x46, 0xe2, 0xd9, + 0x51, 0xfc, 0x33, 0x2f, 0x31, 0x09, 0xa2, 0x9d, 0x7a, 0xa6, 0xd4, 0x0f, 0xae, 0x5f, 0x21, 0x54, + 0x5f, 0x83, 0xe4, 0x5b, 0xd8, 0x60, 0x4a, 0x5d, 0xb0, 0x6b, 0x2c, 0x0c, 0xed, 0xfa, 0x2e, 0x39, + 0xbc, 0xb7, 0xa9, 0x5c, 0xfd, 0x2b, 0xda, 0x99, 0xb0, 0x7a, 0xde, 0xf4, 0xec, 0x22, 0x98, 0x1c, + 0x02, 0x98, 0xb9, 0x48, 0xaf, 0x2c, 0xb3, 0x53, 0x43, 0x7b, 0xc1, 0x66, 0x01, 0x4e, 0xde, 0xc0, + 0x66, 0x6d, 0x69, 0x8b, 0xd9, 0x89, 0xa5, 0x9b, 0x1f, 0x2b, 0xaf, 0xb9, 0xdd, 0x56, 0x1a, 0x92, + 0xc0, 0x96, 0x03, 0xbe, 0xe1, 0x82, 0x9b, 0xb1, 0x4f, 0xbc, 0xf5, 0xd1, 0xf7, 0x76, 0x27, 0x03, + 0x19, 0x40, 0x6f, 0x8c, 0xac, 0xb0, 0xe3, 0x5a, 0xd3, 0x03, 0xa7, 0x29, 0x69, 0x61, 0xe4, 0x10, + 0x36, 0x2b, 0xbb, 0xe9, 0x80, 0x87, 0x9e, 0xd4, 0x06, 0x5d, 0x15, 0xd2, 0x62, 0x6a, 0x2c, 0x6a, + 0xfa, 0xff, 0xb0, 0x0a, 0x35, 0xe8, 0x66, 0xc2, 0x98, 0x1b, 0x2b, 0xf5, 0xfc, 0x3c, 0xa3, 0xa4, + 0x1f, 0x0d, 0x97, 0x9a, 0xfb, 0x5d, 0xc0, 0xe4, 0x25, 0xec, 0x4a, 0xe5, 0x06, 0x20, 0x97, 0xe2, + 0x6a, 0x2e, 0xd2, 0xa4, 0x69, 0xcd, 0xed, 0x20, 0xe3, 0xfd, 0x14, 0xb2, 0x0f, 0xab, 0x4c, 0xa9, + 0xd7, 0xe7, 0xa7, 0x74, 0x27, 0x20, 0xd7, 0x98, 0xeb, 0xcc, 0xba, 0x1d, 0x8c, 0x62, 0x29, 0xd2, + 0xdd, 0xb0, 0x33, 0x43, 0x0f, 0xf9, 0x12, 0xb6, 0x99, 0x52, 0xe7, 0xc2, 0x58, 0x26, 0x52, 0xf4, + 0x85, 0xff, 0x1e, 0xe7, 0xf4, 0x51, 0x10, 0x70, 0x1f, 0xc1, 0xbd, 0x6c, 0xab, 0x59, 0x3a, 0xe1, + 0x22, 0xbf, 0x44, 0x3b, 0x96, 0x19, 0xfd, 0x24, 0x7c, 0xd9, 0x6d, 0xdf, 0xde, 0x57, 0xb0, 0xd5, + 0x6e, 0x36, 0xf2, 0x10, 0x96, 0x26, 0x38, 0xaf, 0xa6, 0x47, 0xe2, 0x96, 0x64, 0x07, 0x56, 0x66, + 0xac, 0x98, 0x62, 0x35, 0x22, 0x92, 0xca, 0x78, 0xd9, 0x79, 0x1e, 0x0d, 0x7e, 0x8b, 0xa0, 0x1b, + 0x8c, 0x37, 0xf7, 0xbe, 0xed, 0x5c, 0x61, 0x6b, 0xf4, 0x78, 0x84, 0xec, 0xc1, 0x4a, 0x81, 0x33, + 0x2c, 0x5a, 0x63, 0xa6, 0x82, 0x5c, 0xc5, 0xca, 0xba, 0xa2, 0xe1, 0x64, 0x69, 0x40, 0x72, 0x01, + 0xeb, 0x05, 0x33, 0xf6, 0x0a, 0x51, 0xf8, 0xb1, 0xf2, 0x5f, 0x5a, 0x78, 0x91, 0x61, 0xf0, 0x16, + 0x7a, 0xa7, 0xa8, 0x50, 0x64, 0x28, 0x52, 0x8e, 0xc6, 0x7d, 0x62, 0x0a, 0x99, 0x4e, 0x6a, 0xc1, + 0x7e, 0xed, 0xb0, 0x0c, 0x95, 0xa9, 0x05, 0xfb, 0xb5, 0xeb, 0x50, 0x8d, 0xbf, 0x4c, 0xb9, 0xc6, + 0xd2, 0x7d, 0xa5, 0xab, 0xa3, 0x26, 0x2d, 0x6c, 0xa0, 0x60, 0xfb, 0x9e, 0xd1, 0x4d, 0x0e, 0x00, + 0x6e, 0x87, 0x77, 0xbd, 0x51, 0x80, 0x90, 0x17, 0xd0, 0xcb, 0x82, 0x23, 0xf9, 0x6d, 0xc3, 0x0f, + 0x4e, 0x78, 0xde, 0xa4, 0x45, 0x7d, 0x75, 0xf2, 0xe1, 0xe6, 0x20, 0xfa, 0xfd, 0xe6, 0x20, 0xfa, + 0xf3, 0xe6, 0x20, 0x7a, 0xfb, 0xd9, 0xbf, 0xfb, 0x55, 0x48, 0x0b, 0x8e, 0xc2, 0xd6, 0xbf, 0x1b, + 0x7f, 0x07, 0x00, 0x00, 0xff, 0xff, 0x57, 0x77, 0xe0, 0x62, 0x8a, 0x08, 0x00, 0x00, } func (m *EventSource) Marshal() (dAtA []byte, err error) {