common

package
v0.0.0-...-1af24f0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 27, 2019 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Overview

+k8s:deepcopy-gen=package

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Event 

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 

func (in *Event) DeepCopy() *Event

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

func (*Event) DeepCopyInto 

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 

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 

func (in *EventContext) DeepCopy() *EventContext

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

func (*EventContext) DeepCopyInto 

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 

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 

func (in *EventProtocol) DeepCopy() *EventProtocol

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

func (*EventProtocol) DeepCopyInto 

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 

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 

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 

func (in *Http) DeepCopy() *Http

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

func (*Http) DeepCopyInto 

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 

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 

func (in *Nats) DeepCopy() *Nats

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

func (*Nats) DeepCopyInto 

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 

type NatsType string

Type of nats connection. 

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

possible values of nats connection type

type S3Artifact 

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 

func (in *S3Artifact) DeepCopy() *S3Artifact

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

func (*S3Artifact) DeepCopyInto 

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 

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 

func (in *S3Bucket) DeepCopy() *S3Bucket

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

func (*S3Bucket) DeepCopyInto 

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 

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 

func (in *S3Filter) DeepCopy() *S3Filter

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

func (*S3Filter) DeepCopyInto 

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 

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 

func (in *ServiceTemplateSpec) DeepCopy() *ServiceTemplateSpec

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

func (*ServiceTemplateSpec) DeepCopyInto 

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 

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 

func (in *URI) DeepCopy() *URI

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

func (*URI) DeepCopyInto 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.