argo-events: github.com/argoproj/argo-events/pkg/apis/common Index | Files

package common

import "github.com/argoproj/argo-events/pkg/apis/common"

+k8s:deepcopy-gen=package

Index

Package Files

deepcopy_generated.go doc.go event.go s3.go

type Event Uses

type Event struct {
    Context EventContext `json:"context" protobuf:"bytes,1,opt,name=context"`
    Payload []byte       `json:"payload" protobuf:"bytes,2,opt,name=data"`
}

Event is a data record expressing an occurrence and its context. Adheres to the CloudEvents v0.1 specification

func (*Event) DeepCopy Uses

func (in *Event) DeepCopy() *Event

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Event.

func (*Event) DeepCopyInto Uses

func (in *Event) DeepCopyInto(out *Event)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EventContext Uses

type EventContext struct {
    // The type of occurrence which has happened. Often this attribute is used for
    // routing, observability, policy enforcement, etc.
    // should be prefixed with a reverse-DNS name. The prefixed domain dictates
    // the organization which defines the semantics of this event type. ex: com.github.pull.create
    EventType string `json:"eventType" protobuf:"bytes,1,opt,name=eventType"`

    // The version of the eventType. Enables the interpretation of data by eventual consumers,
    // requires the consumer to be knowledgeable about the producer.
    EventTypeVersion string `json:"eventTypeVersion" protobuf:"bytes,2,opt,name=eventTypeVersion"`

    // The version of the CloudEvents specification which the event uses.
    // Enables the interpretation of the context.
    CloudEventsVersion string `json:"cloudEventsVersion" protobuf:"bytes,3,opt,name=cloudEventsVersion"`

    // This describes the event producer.
    Source *URI `json:"source" protobuf:"bytes,4,opt,name=source"`

    // ID of the event. The semantics are explicitly undefined to ease the implementation of producers.
    // Enables deduplication. Must be unique within scope of producer.
    EventID string `json:"eventID" protobuf:"bytes,5,opt,name=eventID"`

    EventTime metav1.MicroTime `json:"eventTime" protobuf:"bytes,6,opt,name=eventTime"`

    // A link to the schema that the data attribute adheres to.
    // Must adhere to the format specified in RFC 3986.
    SchemaURL *URI `json:"schemaURL" protobuf:"bytes,7,opt,name=schemaURL"`

    // Content type of the data attribute value. Enables the data attribute to carry any type of content,
    // whereby format and encoding might differ from that of the chosen event format.
    // For example, the data attribute may carry an XML or JSON payload and the consumer is informed
    // by this attribute being set to "application/xml" or "application/json" respectively.
    ContentType string `json:"contentType" protobuf:"bytes,8,opt,name=contentType"`

    // This is for additional metadata and does not have a mandated structure.
    // Enables a place for custom fields a producer or middleware might want to include and provides a place
    // to test metadata before adding them to the CloudEvents specification.
    Extensions map[string]string `json:"extensions,omitempty" protobuf:"bytes,9,rep,name=extensions"`
}

EventContext contains metadata that provides circumstantial information about the occurrence.

func (*EventContext) DeepCopy Uses

func (in *EventContext) DeepCopy() *EventContext

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventContext.

func (*EventContext) DeepCopyInto Uses

func (in *EventContext) DeepCopyInto(out *EventContext)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EventProtocol Uses

type EventProtocol struct {
    Type EventProtocolType `json:"type" protobuf:"bytes,1,opt,name=type"`

    Http Http `json:"http" protobuf:"bytes,2,opt,name=http"`

    Nats Nats `json:"nats" protobuf:"bytes,3,opt,name=nats"`
}

Dispatch protocol contains configuration necessary to dispatch an event to sensor over different communication protocols

func (*EventProtocol) DeepCopy Uses

func (in *EventProtocol) DeepCopy() *EventProtocol

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventProtocol.

func (*EventProtocol) DeepCopyInto Uses

func (in *EventProtocol) DeepCopyInto(out *EventProtocol)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EventProtocolType Uses

type EventProtocolType string

EventProtocolType is type of the event dispatch protocol. Used for dispatching events

const (
    HTTP EventProtocolType = "HTTP"
    NATS EventProtocolType = "NATS"
)

possible types of event dispatch protocol

type Http Uses

type Http struct {
    // Port on which server will run
    Port string `json:"port" protobuf:"bytes,1,opt,name=port"`
}

Http contains the information required to setup a http server and listen to incoming events

func (*Http) DeepCopy Uses

func (in *Http) DeepCopy() *Http

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Http.

func (*Http) DeepCopyInto Uses

func (in *Http) DeepCopyInto(out *Http)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Nats Uses

type Nats struct {
    // URL is nats server/service URL
    URL string `json:"url" protobuf:"bytes,1,opt,name=url"`

    // Subscribe starting with most recently published value. Refer https://github.com/nats-io/go-nats-streaming
    StartWithLastReceived bool `json:"startWithLastReceived,omitempty" protobuf:"bytes,2,opt,name=startWithLastReceived"`

    // Receive all stored values in order.
    DeliverAllAvailable bool `json:"deliverAllAvailable,omitempty" protobuf:"bytes,3,opt,name=deliverAllAvailable"`

    // Receive messages starting at a specific sequence number
    StartAtSequence string `json:"startAtSequence,omitempty" protobuf:"bytes,4,opt,name=startAtSequence"`

    // Subscribe starting at a specific time
    StartAtTime string `json:"startAtTime,omitempty" protobuf:"bytes,5,opt,name=startAtTime"`

    // Subscribe starting a specific amount of time in the past (e.g. 30 seconds ago)
    StartAtTimeDelta string `json:"startAtTimeDelta,omitempty" protobuf:"bytes,6,opt,name=startAtTimeDelta"`

    // Durable subscriptions allow clients to assign a durable name to a subscription when it is created
    Durable bool `json:"durable,omitempty" protobuf:"bytes,7,opt,name=durable"`

    // The NATS Streaming cluster ID
    ClusterId string `json:"clusterId,omitempty" protobuf:"bytes,8,opt,name=clusterId"`

    // The NATS Streaming cluster ID
    ClientId string `json:"clientId,omitempty" protobuf:"bytes,9,opt,name=clientId"`

    // Type of the connection. either standard or streaming
    Type NatsType `json:"type" protobuf:"bytes,10,opt,name=type"`
}

Nats contains the information required to connect to nats server and get subscriptions

func (*Nats) DeepCopy Uses

func (in *Nats) DeepCopy() *Nats

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Nats.

func (*Nats) DeepCopyInto Uses

func (in *Nats) DeepCopyInto(out *Nats)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NatsType Uses

type NatsType string

Type of nats connection.

const (
    Standard  NatsType = "Standard"
    Streaming NatsType = "Streaming"
)

possible values of nats connection type

type S3Artifact Uses

type S3Artifact struct {
    Endpoint  string                    `json:"endpoint" protobuf:"bytes,1,opt,name=endpoint"`
    Bucket    *S3Bucket                 `json:"bucket" protobuf:"bytes,2,opt,name=bucket"`
    Region    string                    `json:"region,omitempty" protobuf:"bytes,3,opt,name=region"`
    Insecure  bool                      `json:"insecure,omitempty" protobuf:"varint,4,opt,name=insecure"`
    AccessKey *corev1.SecretKeySelector `json:"accessKey" protobuf:"bytes,5,opt,name=accessKey"`
    SecretKey *corev1.SecretKeySelector `json:"secretKey" protobuf:"bytes,6,opt,name=secretKey"`
    Events    []string                  `json:"events,omitempty" protobuf:"bytes,7,opt,name=events"`
    Filter    *S3Filter                 `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter"`
}

S3Artifact contains information about an artifact in S3

func (*S3Artifact) DeepCopy Uses

func (in *S3Artifact) DeepCopy() *S3Artifact

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Artifact.

func (*S3Artifact) DeepCopyInto Uses

func (in *S3Artifact) DeepCopyInto(out *S3Artifact)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type S3Bucket Uses

type S3Bucket struct {
    Key  string `json:"key,omitempty" protobuf:"bytes,1,opt,name=key"`
    Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
}

S3Bucket contains information to describe an S3 Bucket

func (*S3Bucket) DeepCopy Uses

func (in *S3Bucket) DeepCopy() *S3Bucket

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Bucket.

func (*S3Bucket) DeepCopyInto Uses

func (in *S3Bucket) DeepCopyInto(out *S3Bucket)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type S3Filter Uses

type S3Filter struct {
    Prefix string `json:"prefix" protobuf:"bytes,1,opt,name=prefix"`
    Suffix string `json:"suffix" protobuf:"bytes,2,opt,name=suffix"`
}

S3Filter represents filters to apply to bucket nofifications for specifying constraints on objects

func (*S3Filter) DeepCopy Uses

func (in *S3Filter) DeepCopy() *S3Filter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Filter.

func (*S3Filter) DeepCopyInto Uses

func (in *S3Filter) DeepCopyInto(out *S3Filter)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ServiceTemplateSpec Uses

type ServiceTemplateSpec struct {
    // Standard object's metadata.
    // More info: https://git.k8s.io/community/contributors/devel/api-conventions.md#metadata
    // +optional
    metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

    // Specification of the desired behavior of the pod.
    // More info: https://git.k8s.io/community/contributors/devel/api-conventions.md#spec-and-status
    // +optional
    Spec corev1.ServiceSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
}

ServiceTemplateSpec is the template spec contains metadata and service spec.

func (*ServiceTemplateSpec) DeepCopy Uses

func (in *ServiceTemplateSpec) DeepCopy() *ServiceTemplateSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceTemplateSpec.

func (*ServiceTemplateSpec) DeepCopyInto Uses

func (in *ServiceTemplateSpec) DeepCopyInto(out *ServiceTemplateSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type URI Uses

type URI struct {
    Scheme   string `json:"scheme" protobuf:"bytes,1,opt,name=scheme"`
    User     string `json:"user" protobuf:"bytes,2,opt,name=user"`
    Password string `json:"password" protobuf:"bytes,3,opt,name=password"`
    Host     string `json:"host" protobuf:"bytes,4,opt,name=host"`
    Port     int32  `json:"port" protobuf:"bytes,5,opt,name=port"`
    Path     string `json:"path" protobuf:"bytes,6,opt,name=path"`
    Query    string `json:"query" protobuf:"bytes,7,opt,name=query"`
    Fragment string `json:"fragment" protobuf:"bytes,8,opt,name=fragment"`
}

URI is a Uniform Resource Identifier based on RFC 3986

func (*URI) DeepCopy Uses

func (in *URI) DeepCopy() *URI

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new URI.

func (*URI) DeepCopyInto Uses

func (in *URI) DeepCopyInto(out *URI)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Package common imports 2 packages (graph) and is imported by 13 packages. Updated 2019-05-09. Refresh now. Tools for package owners.