gateways

Jun 14, 2020 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

May 8, 2020 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Apr 12, 2020 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 21, 2020 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

+ const EventSourceDir

type EventSource

+ Type string

+ Value []byte

+ func (m *EventSource) GetType() string

+ func (m *EventSource) GetValue() []byte

Feb 26, 2020 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Jun 28, 2019 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

+ type UnimplementedEventingServer struct

+ func (*UnimplementedEventingServer) StartEventSource(req *EventSource, srv Eventing_StartEventSourceServer) error

+ func (*UnimplementedEventingServer) ValidateEventSource(ctx context.Context, req *EventSource) (*ValidEventSource, error)

Apr 25, 2019 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Apr 25, 2019 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type EventSource

+ Version string

+ func (m *EventSource) GetVersion() string

type EventSourceContext

+ Source *EventSource

Mar 18, 2019 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 13, 2019 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 10, 2019 GO-2022-0490 +1 more

  GO-2022-0490: Uses of deprecated API can be used to cause DoS in user-facing endpoints in github.com/argoproj/argo-events

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

+ func Connect(backoff *wait.Backoff, conn func() error) error

+ func HandleEventsFromEventSource(name string, eventStream Eventing_StartEventSourceServer, dataCh chan []byte, ...) error

+ func Hasher(value string) string

+ func InitBackoff(backoff *wait.Backoff)

+ func Recover(eventSource string)

+ func RegisterEventingServer(s *grpc.Server, srv EventingServer)

+ func SetValidEventSource(v *ValidEventSource, reason string, valid bool)

+ func StartGateway(es EventingServer)

+ type Event struct

+ Name string

+ Payload []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Event) Descriptor() ([]byte, []int)

+ func (*Event) ProtoMessage()

+ func (m *Event) GetName() string

+ func (m *Event) GetPayload() []byte

+ func (m *Event) Reset()

+ func (m *Event) String() string

+ func (m *Event) XXX_DiscardUnknown()

+ func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Event) XXX_Merge(src proto.Message)

+ func (m *Event) XXX_Size() int

+ func (m *Event) XXX_Unmarshal(b []byte) error

+ type EventSource struct

+ Data string

+ Id string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EventSource) Descriptor() ([]byte, []int)

+ func (*EventSource) ProtoMessage()

+ func (m *EventSource) GetData() string

+ func (m *EventSource) GetId() string

+ func (m *EventSource) GetName() string

+ func (m *EventSource) Reset()

+ func (m *EventSource) String() string

+ func (m *EventSource) XXX_DiscardUnknown()

+ func (m *EventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventSource) XXX_Merge(src proto.Message)

+ func (m *EventSource) XXX_Size() int

+ func (m *EventSource) XXX_Unmarshal(b []byte) error

+ type EventSourceContext struct

+ Cancel context.CancelFunc

+ Client EventingClient

+ Conn *grpc.ClientConn

+ Ctx context.Context

+ Data *EventSourceData

+ type EventSourceData struct

+ Config string

+ ID string

+ Src string

+ type EventSourceStatus struct

+ Gw *v1alpha1.Gateway

+ Id string

+ Message string

+ Name string

+ Phase v1alpha1.NodePhase

+ type EventingClient interface

+ StartEventSource func(ctx context.Context, in *EventSource, opts ...grpc.CallOption) (Eventing_StartEventSourceClient, error)

+ ValidateEventSource func(ctx context.Context, in *EventSource, opts ...grpc.CallOption) (*ValidEventSource, error)

+ func NewEventingClient(cc *grpc.ClientConn) EventingClient

+ type EventingServer interface

+ StartEventSource func(*EventSource, Eventing_StartEventSourceServer) error

+ ValidateEventSource func(context.Context, *EventSource) (*ValidEventSource, error)

+ type Eventing_StartEventSourceClient interface

+ Recv func() (*Event, error)

+ type Eventing_StartEventSourceServer interface

+ Send func(*Event) error

+ type GatewayConfig struct

+ Clientset kubernetes.Interface

+ KubeConfig *rest.Config

+ Log zerolog.Logger

+ Name string

+ Namespace string

+ StatusCh chan EventSourceStatus

+ func NewGatewayConfiguration() *GatewayConfig

+ func (gc *GatewayConfig) DispatchEvent(gatewayEvent *Event) error

+ func (gc *GatewayConfig) UpdateGatewayResourceState(status *EventSourceStatus)

+ func (gc *GatewayConfig) WatchGateway(ctx context.Context) (cache.Controller, error)

+ func (gc *GatewayConfig) WatchGatewayEventSources(ctx context.Context) (cache.Controller, error)

+ type GatewayEvent struct

+ Payload []byte

+ Src string

+ type TransformerPayload struct

+ Payload []byte

+ Src string

+ type ValidEventSource struct

+ IsValid bool

+ Reason string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ValidEventSource) Descriptor() ([]byte, []int)

+ func (*ValidEventSource) ProtoMessage()

+ func (m *ValidEventSource) GetIsValid() bool

+ func (m *ValidEventSource) GetReason() string

+ func (m *ValidEventSource) Reset()

+ func (m *ValidEventSource) String() string

+ func (m *ValidEventSource) XXX_DiscardUnknown()

+ func (m *ValidEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ValidEventSource) XXX_Merge(src proto.Message)

+ func (m *ValidEventSource) XXX_Size() int

+ func (m *ValidEventSource) XXX_Unmarshal(b []byte) error