v1alpha1

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API. +groupName=argoproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// SchemeBuilder is the builder for this scheme
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

	// AddToScheme adds this
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var SchemaGroupVersionKind = schema.GroupVersionKind{Group: gateway.Group, Version: "v1alpha1", Kind: gateway.Kind}

SchemaGroupVersionKind is a group version kind used to attach owner references to gateway-controller

View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: gateway.Group, Version: "v1alpha1"}

SchemeGroupVersion is a group version used to register these objects

Functions

func GetOpenAPIDefinitions 

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes unqualified resource and returns Group qualified GroupResource

Types

type EventSourceRef added in v0.13.0 

type EventSourceRef struct {
	// Name of the event source
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Namespace of the event source
	// Default value is the namespace where referencing gateway is deployed
	// +optional
	Namespace string `json:"namespace,omitempty" protobuf:"bytes,2,opt,name=namespace"`
}

EventSourceRef holds information about the EventSourceRef custom resource

func (*EventSourceRef) DeepCopy added in v0.13.0 

func (in *EventSourceRef) DeepCopy() *EventSourceRef

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

func (*EventSourceRef) DeepCopyInto added in v0.13.0 

func (in *EventSourceRef) DeepCopyInto(out *EventSourceRef)

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

func (*EventSourceRef) Descriptor added in v0.17.0 

func (*EventSourceRef) Descriptor() ([]byte, []int)

func (*EventSourceRef) Marshal added in v0.17.0 

func (m *EventSourceRef) Marshal() (dAtA []byte, err error)

func (*EventSourceRef) MarshalTo added in v0.17.0 

func (m *EventSourceRef) MarshalTo(dAtA []byte) (int, error)

func (*EventSourceRef) MarshalToSizedBuffer added in v0.17.0 

func (m *EventSourceRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventSourceRef) ProtoMessage added in v0.17.0 

func (*EventSourceRef) ProtoMessage()

func (*EventSourceRef) Reset added in v0.17.0 

func (m *EventSourceRef) Reset()

func (*EventSourceRef) Size added in v0.17.0 

func (m *EventSourceRef) Size() (n int)

func (*EventSourceRef) String added in v0.17.0 

func (this *EventSourceRef) String() string

func (*EventSourceRef) Unmarshal added in v0.17.0 

func (m *EventSourceRef) Unmarshal(dAtA []byte) error

func (*EventSourceRef) XXX_DiscardUnknown added in v0.17.0 

func (m *EventSourceRef) XXX_DiscardUnknown()

func (*EventSourceRef) XXX_Marshal added in v0.17.0 

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

func (*EventSourceRef) XXX_Merge added in v0.17.0 

func (m *EventSourceRef) XXX_Merge(src proto.Message)

func (*EventSourceRef) XXX_Size added in v0.17.0 

func (m *EventSourceRef) XXX_Size() int

func (*EventSourceRef) XXX_Unmarshal added in v0.17.0 

func (m *EventSourceRef) XXX_Unmarshal(b []byte) error

type Gateway 

type Gateway struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Status            GatewayStatus `json:"status" protobuf:"bytes,2,opt,name=status"`
	Spec              GatewaySpec   `json:"spec" protobuf:"bytes,3,opt,name=spec"`
}

Gateway is the definition of a gateway resource +genclient +kubebuilder:resource:shortName=gw +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true

func (*Gateway) DeepCopy 

func (in *Gateway) DeepCopy() *Gateway

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

func (*Gateway) DeepCopyInto 

func (in *Gateway) DeepCopyInto(out *Gateway)

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

func (*Gateway) DeepCopyObject 

func (in *Gateway) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Gateway) Descriptor 

func (*Gateway) Descriptor() ([]byte, []int)

func (*Gateway) Marshal 

func (m *Gateway) Marshal() (dAtA []byte, err error)

func (*Gateway) MarshalTo 

func (m *Gateway) MarshalTo(dAtA []byte) (int, error)

func (*Gateway) MarshalToSizedBuffer added in v0.17.0 

func (m *Gateway) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Gateway) ProtoMessage 

func (*Gateway) ProtoMessage()

func (*Gateway) Reset 

func (m *Gateway) Reset()

func (*Gateway) Size 

func (m *Gateway) Size() (n int)

func (*Gateway) String 

func (this *Gateway) String() string

func (*Gateway) Unmarshal 

func (m *Gateway) Unmarshal(dAtA []byte) error

func (*Gateway) XXX_DiscardUnknown 

func (m *Gateway) XXX_DiscardUnknown()

func (*Gateway) XXX_Marshal 

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

func (*Gateway) XXX_Merge 

func (m *Gateway) XXX_Merge(src proto.Message)

func (*Gateway) XXX_Size 

func (m *Gateway) XXX_Size() int

func (*Gateway) XXX_Unmarshal 

func (m *Gateway) XXX_Unmarshal(b []byte) error

type GatewayList 

type GatewayList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`

	Items []Gateway `json:"items" protobuf:"bytes,2,rep,name=items"`
}

GatewayList is the list of Gateway resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*GatewayList) DeepCopy 

func (in *GatewayList) DeepCopy() *GatewayList

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

func (*GatewayList) DeepCopyInto 

func (in *GatewayList) DeepCopyInto(out *GatewayList)

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

func (*GatewayList) DeepCopyObject 

func (in *GatewayList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*GatewayList) Descriptor 

func (*GatewayList) Descriptor() ([]byte, []int)

func (*GatewayList) Marshal 

func (m *GatewayList) Marshal() (dAtA []byte, err error)

func (*GatewayList) MarshalTo 

func (m *GatewayList) MarshalTo(dAtA []byte) (int, error)

func (*GatewayList) MarshalToSizedBuffer added in v0.17.0 

func (m *GatewayList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GatewayList) ProtoMessage 

func (*GatewayList) ProtoMessage()

func (*GatewayList) Reset 

func (m *GatewayList) Reset()

func (*GatewayList) Size 

func (m *GatewayList) Size() (n int)

func (*GatewayList) String 

func (this *GatewayList) String() string

func (*GatewayList) Unmarshal 

func (m *GatewayList) Unmarshal(dAtA []byte) error

func (*GatewayList) XXX_DiscardUnknown 

func (m *GatewayList) XXX_DiscardUnknown()

func (*GatewayList) XXX_Marshal 

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

func (*GatewayList) XXX_Merge 

func (m *GatewayList) XXX_Merge(src proto.Message)

func (*GatewayList) XXX_Size 

func (m *GatewayList) XXX_Size() int

func (*GatewayList) XXX_Unmarshal 

func (m *GatewayList) XXX_Unmarshal(b []byte) error

type GatewayResource added in v0.13.0 

type GatewayResource struct {
	// Metadata of the deployment for the gateway
	Deployment *metav1.ObjectMeta `json:"deployment,omitempty" protobuf:"bytes,1,opt,name=deployment"`
	// Metadata of the service for the gateway
	// +optional
	Service *metav1.ObjectMeta `json:"service,omitempty" protobuf:"bytes,2,opt,name=service"`
}

GatewayResource holds the metadata about the gateway resources

func (*GatewayResource) DeepCopy added in v0.13.0 

func (in *GatewayResource) DeepCopy() *GatewayResource

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

func (*GatewayResource) DeepCopyInto added in v0.13.0 

func (in *GatewayResource) DeepCopyInto(out *GatewayResource)

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

func (*GatewayResource) Descriptor added in v0.17.0 

func (*GatewayResource) Descriptor() ([]byte, []int)

func (*GatewayResource) Marshal added in v0.17.0 

func (m *GatewayResource) Marshal() (dAtA []byte, err error)

func (*GatewayResource) MarshalTo added in v0.17.0 

func (m *GatewayResource) MarshalTo(dAtA []byte) (int, error)

func (*GatewayResource) MarshalToSizedBuffer added in v0.17.0 

func (m *GatewayResource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GatewayResource) ProtoMessage added in v0.17.0 

func (*GatewayResource) ProtoMessage()

func (*GatewayResource) Reset added in v0.17.0 

func (m *GatewayResource) Reset()

func (*GatewayResource) Size added in v0.17.0 

func (m *GatewayResource) Size() (n int)

func (*GatewayResource) String added in v0.17.0 

func (this *GatewayResource) String() string

func (*GatewayResource) Unmarshal added in v0.17.0 

func (m *GatewayResource) Unmarshal(dAtA []byte) error

func (*GatewayResource) XXX_DiscardUnknown added in v0.17.0 

func (m *GatewayResource) XXX_DiscardUnknown()

func (*GatewayResource) XXX_Marshal added in v0.17.0 

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

func (*GatewayResource) XXX_Merge added in v0.17.0 

func (m *GatewayResource) XXX_Merge(src proto.Message)

func (*GatewayResource) XXX_Size added in v0.17.0 

func (m *GatewayResource) XXX_Size() int

func (*GatewayResource) XXX_Unmarshal added in v0.17.0 

func (m *GatewayResource) XXX_Unmarshal(b []byte) error

type GatewaySpec 

type GatewaySpec struct {
	// Template is the pod specification for the gateway
	// +optional
	Template Template `json:"template,omitempty" protobuf:"bytes,1,opt,name=template"`
	// EventSourceRef refers to event-source that stores event source configurations for the gateway
	EventSourceRef *EventSourceRef `json:"eventSourceRef,omitempty" protobuf:"bytes,2,opt,name=eventSourceRef"`
	// Type is the type of gateway. Used as metadata.
	Type apicommon.EventSourceType `json:"type" protobuf:"bytes,3,opt,name=type,casttype=github.com/argoproj/argo-events/pkg/apis/common.EventSourceType"`
	// Service is the specifications of the service to expose the gateway
	// +optional
	Service *Service `json:"service,omitempty" protobuf:"bytes,4,opt,name=service"`
	// Port on which the gateway event source processor is running on.
	ProcessorPort string `json:"processorPort" protobuf:"bytes,5,opt,name=processorPort"`
	// Replica is the gateway deployment replicas
	Replica int32 `json:"replica,omitempty" protobuf:"varint,6,opt,name=replica"`
	// EventBusName references to a EventBus name. By default the value is "default"
	EventBusName string `json:"eventBusName,omitempty" protobuf:"bytes,7,opt,name=eventBusName"`
}

GatewaySpec represents gateway specifications

func (*GatewaySpec) DeepCopy 

func (in *GatewaySpec) DeepCopy() *GatewaySpec

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

func (*GatewaySpec) DeepCopyInto 

func (in *GatewaySpec) DeepCopyInto(out *GatewaySpec)

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

func (*GatewaySpec) Descriptor 

func (*GatewaySpec) Descriptor() ([]byte, []int)

func (*GatewaySpec) Marshal 

func (m *GatewaySpec) Marshal() (dAtA []byte, err error)

func (*GatewaySpec) MarshalTo 

func (m *GatewaySpec) MarshalTo(dAtA []byte) (int, error)

func (*GatewaySpec) MarshalToSizedBuffer added in v0.17.0 

func (m *GatewaySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GatewaySpec) ProtoMessage 

func (*GatewaySpec) ProtoMessage()

func (*GatewaySpec) Reset 

func (m *GatewaySpec) Reset()

func (*GatewaySpec) Size 

func (m *GatewaySpec) Size() (n int)

func (*GatewaySpec) String 

func (this *GatewaySpec) String() string

func (*GatewaySpec) Unmarshal 

func (m *GatewaySpec) Unmarshal(dAtA []byte) error

func (*GatewaySpec) XXX_DiscardUnknown 

func (m *GatewaySpec) XXX_DiscardUnknown()

func (*GatewaySpec) XXX_Marshal 

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

func (*GatewaySpec) XXX_Merge 

func (m *GatewaySpec) XXX_Merge(src proto.Message)

func (*GatewaySpec) XXX_Size 

func (m *GatewaySpec) XXX_Size() int

func (*GatewaySpec) XXX_Unmarshal 

func (m *GatewaySpec) XXX_Unmarshal(b []byte) error

type GatewayStatus 

type GatewayStatus struct {
	// Phase is the high-level summary of the gateway
	Phase NodePhase `json:"phase" protobuf:"bytes,1,opt,name=phase,casttype=NodePhase"`
	// StartedAt is the time at which this gateway was initiated
	StartedAt metav1.Time `json:"startedAt,omitempty" protobuf:"bytes,2,opt,name=startedAt"`
	// Message is a human readable string indicating details about a gateway in its phase
	Message string `json:"message,omitempty" protobuf:"bytes,3,opt,name=message"`
	// Nodes is a mapping between a node ID and the node's status
	// it records the states for the configurations of gateway.
	Nodes map[string]NodeStatus `json:"nodes,omitempty" protobuf:"bytes,4,rep,name=nodes"`
	// Resources refers to the metadata about the gateway resources
	Resources *GatewayResource `json:"resources,omitempty" protobuf:"bytes,5,opt,name=resources"`
}

GatewayStatus contains information about the status of a gateway.

func (*GatewayStatus) DeepCopy 

func (in *GatewayStatus) DeepCopy() *GatewayStatus

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

func (*GatewayStatus) DeepCopyInto 

func (in *GatewayStatus) DeepCopyInto(out *GatewayStatus)

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

func (*GatewayStatus) Descriptor 

func (*GatewayStatus) Descriptor() ([]byte, []int)

func (*GatewayStatus) Marshal 

func (m *GatewayStatus) Marshal() (dAtA []byte, err error)

func (*GatewayStatus) MarshalTo 

func (m *GatewayStatus) MarshalTo(dAtA []byte) (int, error)

func (*GatewayStatus) MarshalToSizedBuffer added in v0.17.0 

func (m *GatewayStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GatewayStatus) ProtoMessage 

func (*GatewayStatus) ProtoMessage()

func (*GatewayStatus) Reset 

func (m *GatewayStatus) Reset()

func (*GatewayStatus) Size 

func (m *GatewayStatus) Size() (n int)

func (*GatewayStatus) String 

func (this *GatewayStatus) String() string

func (*GatewayStatus) Unmarshal 

func (m *GatewayStatus) Unmarshal(dAtA []byte) error

func (*GatewayStatus) XXX_DiscardUnknown 

func (m *GatewayStatus) XXX_DiscardUnknown()

func (*GatewayStatus) XXX_Marshal 

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

func (*GatewayStatus) XXX_Merge 

func (m *GatewayStatus) XXX_Merge(src proto.Message)

func (*GatewayStatus) XXX_Size 

func (m *GatewayStatus) XXX_Size() int

func (*GatewayStatus) XXX_Unmarshal 

func (m *GatewayStatus) XXX_Unmarshal(b []byte) error

type Metadata added in v0.16.0 

type Metadata struct {
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,1,rep,name=annotations"`
	Labels      map[string]string `json:"labels,omitempty" protobuf:"bytes,2,rep,name=labels"`
}

Metadata holds the annotations and labels of a gateway pod

func (*Metadata) DeepCopy added in v0.16.0 

func (in *Metadata) DeepCopy() *Metadata

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

func (*Metadata) DeepCopyInto added in v0.16.0 

func (in *Metadata) DeepCopyInto(out *Metadata)

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

func (*Metadata) Descriptor added in v0.17.0 

func (*Metadata) Descriptor() ([]byte, []int)

func (*Metadata) Marshal added in v0.17.0 

func (m *Metadata) Marshal() (dAtA []byte, err error)

func (*Metadata) MarshalTo added in v0.17.0 

func (m *Metadata) MarshalTo(dAtA []byte) (int, error)

func (*Metadata) MarshalToSizedBuffer added in v0.17.0 

func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metadata) ProtoMessage added in v0.17.0 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset added in v0.17.0 

func (m *Metadata) Reset()

func (*Metadata) Size added in v0.17.0 

func (m *Metadata) Size() (n int)

func (*Metadata) String added in v0.17.0 

func (this *Metadata) String() string

func (*Metadata) Unmarshal added in v0.17.0 

func (m *Metadata) Unmarshal(dAtA []byte) error

func (*Metadata) XXX_DiscardUnknown added in v0.17.0 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal added in v0.17.0 

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

func (*Metadata) XXX_Merge added in v0.17.0 

func (m *Metadata) XXX_Merge(src proto.Message)

func (*Metadata) XXX_Size added in v0.17.0 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal added in v0.17.0 

func (m *Metadata) XXX_Unmarshal(b []byte) error

type NodePhase 

type NodePhase string

NodePhase is the label for the condition of a node. 

const (
	NodePhaseRunning   NodePhase = "Running"   // the node is running
	NodePhaseError     NodePhase = "Error"     // the node has encountered an error in processing
	NodePhaseNew       NodePhase = ""          // the node is new
	NodePhaseCompleted NodePhase = "Completed" // node has completed running
	NodePhaseRemove    NodePhase = "Remove"    // stale node
)

possible types of node phases

type NodeStatus 

type NodeStatus struct {
	// ID is a unique identifier of a node within a sensor
	// It is a hash of the node name
	ID string `json:"id" protobuf:"bytes,1,opt,name=id"`
	// Name is a unique name in the node tree used to generate the node ID
	Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
	// DisplayName is the human readable representation of the node
	DisplayName string `json:"displayName" protobuf:"bytes,3,opt,name=displayName"`
	// Phase of the node
	Phase NodePhase `json:"phase" protobuf:"bytes,4,opt,name=phase,casttype=NodePhase"`
	// StartedAt is the time at which this node started
	// +k8s:openapi-gen=false
	StartedAt metav1.MicroTime `json:"startedAt,omitempty" protobuf:"bytes,5,opt,name=startedAt"`
	// Message store data or something to save for configuration
	Message string `json:"message,omitempty" protobuf:"bytes,6,opt,name=message"`
	// UpdateTime is the time when node(gateway configuration) was updated
	UpdateTime metav1.MicroTime `json:"updateTime,omitempty" protobuf:"bytes,7,opt,name=updateTime"`
}

NodeStatus describes the status for an individual node in the gateway configurations. A single node can represent one configuration.

func (*NodeStatus) DeepCopy 

func (in *NodeStatus) DeepCopy() *NodeStatus

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

func (*NodeStatus) DeepCopyInto 

func (in *NodeStatus) DeepCopyInto(out *NodeStatus)

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

func (*NodeStatus) Descriptor 

func (*NodeStatus) Descriptor() ([]byte, []int)

func (*NodeStatus) Marshal 

func (m *NodeStatus) Marshal() (dAtA []byte, err error)

func (*NodeStatus) MarshalTo 

func (m *NodeStatus) MarshalTo(dAtA []byte) (int, error)

func (*NodeStatus) MarshalToSizedBuffer added in v0.17.0 

func (m *NodeStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeStatus) ProtoMessage 

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) Reset 

func (m *NodeStatus) Reset()

func (*NodeStatus) Size 

func (m *NodeStatus) Size() (n int)

func (*NodeStatus) String 

func (this *NodeStatus) String() string

func (*NodeStatus) Unmarshal 

func (m *NodeStatus) Unmarshal(dAtA []byte) error

func (*NodeStatus) XXX_DiscardUnknown 

func (m *NodeStatus) XXX_DiscardUnknown()

func (*NodeStatus) XXX_Marshal 

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

func (*NodeStatus) XXX_Merge 

func (m *NodeStatus) XXX_Merge(src proto.Message)

func (*NodeStatus) XXX_Size 

func (m *NodeStatus) XXX_Size() int

func (*NodeStatus) XXX_Unmarshal 

func (m *NodeStatus) XXX_Unmarshal(b []byte) error

type Service added in v0.15.0 

type Service struct {
	// The list of ports that are exposed by this ClusterIP service.
	// +patchMergeKey=port
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=port
	// +listMapKey=protocol
	Ports []corev1.ServicePort `json:"ports,omitempty" patchStrategy:"merge" patchMergeKey:"port" protobuf:"bytes,1,rep,name=ports"`
	// clusterIP is the IP address of the service and is usually assigned
	// randomly by the master. If an address is specified manually and is not in
	// use by others, it will be allocated to the service; otherwise, creation
	// of the service will fail. This field can not be changed through updates.
	// Valid values are "None", empty string (""), or a valid IP address. "None"
	// can be specified for headless services when proxying is not required.
	// More info: https://kubernetes.io/docs/concepts/services-networking/service/#virtual-ips-and-service-proxies
	// +optional
	ClusterIP string `json:"clusterIP,omitempty" protobuf:"bytes,2,opt,name=clusterIP"`
	// Spec holds the gateway service spec.
	// DEPRECATED: Use Ports to declare the ports to be exposed.
	Spec *corev1.ServiceSpec `json:"spec,omitempty" protobuf:"bytes,3,opt,name=spec"`
}

Service holds the service information gateway exposes

func (*Service) DeepCopy added in v0.15.0 

func (in *Service) DeepCopy() *Service

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

func (*Service) DeepCopyInto added in v0.15.0 

func (in *Service) DeepCopyInto(out *Service)

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

func (*Service) Descriptor added in v0.17.0 

func (*Service) Descriptor() ([]byte, []int)

func (*Service) Marshal added in v0.17.0 

func (m *Service) Marshal() (dAtA []byte, err error)

func (*Service) MarshalTo added in v0.17.0 

func (m *Service) MarshalTo(dAtA []byte) (int, error)

func (*Service) MarshalToSizedBuffer added in v0.17.0 

func (m *Service) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Service) ProtoMessage added in v0.17.0 

func (*Service) ProtoMessage()

func (*Service) Reset added in v0.17.0 

func (m *Service) Reset()

func (*Service) Size added in v0.17.0 

func (m *Service) Size() (n int)

func (*Service) String added in v0.17.0 

func (this *Service) String() string

func (*Service) Unmarshal added in v0.17.0 

func (m *Service) Unmarshal(dAtA []byte) error

func (*Service) XXX_DiscardUnknown added in v0.17.0 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal added in v0.17.0 

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

func (*Service) XXX_Merge added in v0.17.0 

func (m *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size added in v0.17.0 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal added in v0.17.0 

func (m *Service) XXX_Unmarshal(b []byte) error

type Template added in v0.15.0 

type Template struct {
	// Metdata sets the pods's metadata, i.e. annotations and labels
	Metadata Metadata `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	// ServiceAccountName is the name of the ServiceAccount to use to run gateway pod.
	// More info: https://kubernetes.io/docs/tasks/configure-pod-container/configure-service-account/
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,2,opt,name=serviceAccountName"`
	// Container is the main container image to run in the gateway pod
	// +optional
	Container *corev1.Container `json:"container,omitempty" protobuf:"bytes,3,opt,name=container"`
	// Volumes is a list of volumes that can be mounted by containers in a workflow.
	// +patchStrategy=merge
	// +patchMergeKey=name
	// +optional
	Volumes []corev1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,4,rep,name=volumes"`
	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,5,opt,name=securityContext"`
	// If specified, the pod's scheduling constraints
	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty" protobuf:"bytes,6,opt,name=affinity"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,7,rep,name=tolerations"`
	// Spec holds the gateway deployment spec.
	// DEPRECATED: Use Container instead.
	Spec *corev1.PodSpec `json:"spec,omitempty" protobuf:"bytes,8,opt,name=spec"`
}

Template holds the information of a Gateway deployment template

func (*Template) DeepCopy added in v0.15.0 

func (in *Template) DeepCopy() *Template

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

func (*Template) DeepCopyInto added in v0.15.0 

func (in *Template) DeepCopyInto(out *Template)

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

func (*Template) Descriptor added in v0.17.0 

func (*Template) Descriptor() ([]byte, []int)

func (*Template) Marshal added in v0.17.0 

func (m *Template) Marshal() (dAtA []byte, err error)

func (*Template) MarshalTo added in v0.17.0 

func (m *Template) MarshalTo(dAtA []byte) (int, error)

func (*Template) MarshalToSizedBuffer added in v0.17.0 

func (m *Template) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Template) ProtoMessage added in v0.17.0 

func (*Template) ProtoMessage()

func (*Template) Reset added in v0.17.0 

func (m *Template) Reset()

func (*Template) Size added in v0.17.0 

func (m *Template) Size() (n int)

func (*Template) String added in v0.17.0 

func (this *Template) String() string

func (*Template) Unmarshal added in v0.17.0 

func (m *Template) Unmarshal(dAtA []byte) error

func (*Template) XXX_DiscardUnknown added in v0.17.0 

func (m *Template) XXX_DiscardUnknown()

func (*Template) XXX_Marshal added in v0.17.0 

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

func (*Template) XXX_Merge added in v0.17.0 

func (m *Template) XXX_Merge(src proto.Message)

func (*Template) XXX_Size added in v0.17.0 

func (m *Template) XXX_Size() int

func (*Template) XXX_Unmarshal added in v0.17.0 

func (m *Template) XXX_Unmarshal(b []byte) error

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.