Documentation
¶
Index ¶
- type Args
- type AuthOverride
- type Clients
- type DefaultAuthOverride
- type Response
- type Sink
- func (r Sink) CreateResources(triggerNS, sa string, res []json.RawMessage, triggerName, eventID string, ...) error
- func (r Sink) ExecuteInterceptors(t triggersv1.Trigger, in *http.Request, event []byte, log *zap.SugaredLogger, ...) ([]byte, http.Header, *triggersv1.InterceptorResponse, error)
- func (r Sink) HandleEvent(response http.ResponseWriter, request *http.Request)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Args ¶
type Args struct {
// ElName is the EventListener name.
ElName string
// ElNamespace is the EventListener namespace.
ElNamespace string
// Port is the port the Sink should listen on.
Port string
// ELReadTimeOut defines the read timeout for EventListener Server
ELReadTimeOut time.Duration
// ELWriteTimeOut defines the write timeout for EventListener Server
ELWriteTimeOut time.Duration
// ELIdleTimeOut defines the read timeout for EventListener Server
ELIdleTimeOut time.Duration
// ELTimeOutHandler defines the timeout for Timeout Handler of EventListener Server
ELTimeOutHandler time.Duration
// IsMultiNS determines whether el functions as namespaced or clustered
IsMultiNS bool
// Key defines the filename for tls Key.
Key string
// Cert defines the filename for tls Cert.
Cert string
}
Args define the arguments for Sink.
type AuthOverride ¶ added in v0.4.0
type AuthOverride interface {
OverrideAuthentication(sa string,
namespace string,
log *zap.SugaredLogger,
defaultDiscoveryClient discoveryclient.ServerResourcesInterface,
defaultDynamicClient dynamic.Interface) (discoveryClient discoveryclient.ServerResourcesInterface,
dynamicClient dynamic.Interface,
err error)
}
AuthOverride is an interface that constructs a discovery client for the ServerResourceInterface and a dynamic client for the Tekton Resources, using the token provide as the bearer token in the REST config used to build those client. The other non-credential related parameters for the REST client used are copied from the in cluster config of the event sink.
type Clients ¶
type Clients struct {
DiscoveryClient discoveryclient.DiscoveryInterface
RESTClient restclient.Interface
TriggersClient triggersclientset.Interface
}
Clients define the set of client dependencies Sink requires.
type DefaultAuthOverride ¶ added in v0.4.0
type DefaultAuthOverride struct {
}
func (DefaultAuthOverride) OverrideAuthentication ¶ added in v0.4.0
func (r DefaultAuthOverride) OverrideAuthentication(sa string, namespace string, log *zap.SugaredLogger, defaultDiscoverClient discoveryclient.ServerResourcesInterface, defaultDynamicClient dynamic.Interface) (discoveryClient discoveryclient.ServerResourcesInterface, dynamicClient dynamic.Interface, err error)
type Response ¶ added in v0.2.0
type Response struct {
// EventListener is the name of the eventListener
EventListener string `json:"eventListener"`
// Namespace is the namespace that the eventListener is running in
Namespace string `json:"namespace,omitempty"`
// EventID is a uniqueID that gets assigned to each incoming request
EventID string `json:"eventID,omitempty"`
}
Response defines the HTTP body that the Sink responds to events with.
type Sink ¶ added in v0.2.0
type Sink struct {
KubeClientSet kubernetes.Interface
TriggersClient triggersclientset.Interface
DiscoveryClient discoveryclient.ServerResourcesInterface
DynamicClient dynamic.Interface
HTTPClient *http.Client
EventListenerName string
EventListenerNamespace string
Logger *zap.SugaredLogger
Auth AuthOverride
// listers index properties about resources
EventListenerLister listers.EventListenerLister
TriggerLister listers.TriggerLister
TriggerBindingLister listers.TriggerBindingLister
ClusterTriggerBindingLister listers.ClusterTriggerBindingLister
TriggerTemplateLister listers.TriggerTemplateLister
}
Sink defines the sink resource for processing incoming events for the EventListener.
func (Sink) CreateResources ¶ added in v0.8.0
func (r Sink) CreateResources(triggerNS, sa string, res []json.RawMessage, triggerName, eventID string, log *zap.SugaredLogger) error
func (Sink) ExecuteInterceptors ¶ added in v0.8.0
func (r Sink) ExecuteInterceptors(t triggersv1.Trigger, in *http.Request, event []byte, log *zap.SugaredLogger, eventID string) ([]byte, http.Header, *triggersv1.InterceptorResponse, error)
ExecuteInterceptor executes all interceptors for the Trigger and returns back the body, header, and InterceptorResponse to use. When TEP-0022 is fully implemented, this function will only return the InterceptorResponse and error.
func (Sink) HandleEvent ¶ added in v0.2.0
func (r Sink) HandleEvent(response http.ResponseWriter, request *http.Request)
HandleEvent processes an incoming HTTP event for the event listener.