v1

package
v0.0.0-...-ff55af6 Latest Latest
Warning

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

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

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthInstaller = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInstaller   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterInstallerHandler 

func RegisterInstallerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterInstallerHandler registers the http handlers for service Installer to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterInstallerHandlerClient 

func RegisterInstallerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InstallerClient) error

RegisterInstallerHandlerClient registers the http handlers for service Installer to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InstallerClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InstallerClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InstallerClient" to call the correct interceptors.

func RegisterInstallerHandlerFromEndpoint 

func RegisterInstallerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterInstallerHandlerFromEndpoint is same as RegisterInstallerHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterInstallerHandlerServer 

func RegisterInstallerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InstallerServer) error

RegisterInstallerHandlerServer registers the http handlers for service Installer to "mux". UnaryRPC :call InstallerServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterInstallerServer 

func RegisterInstallerServer(s *grpc.Server, srv InstallerServer)

Types

type Addons 

type Addons struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Addons) Descriptor 

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

func (*Addons) Marshal 

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

func (*Addons) MarshalTo 

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

func (*Addons) ProtoMessage 

func (*Addons) ProtoMessage()

func (*Addons) Reset 

func (m *Addons) Reset()

func (*Addons) Size 

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

func (*Addons) String 

func (m *Addons) String() string

func (*Addons) Unmarshal 

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

func (*Addons) XXX_DiscardUnknown 

func (m *Addons) XXX_DiscardUnknown()

func (*Addons) XXX_Marshal 

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

func (*Addons) XXX_Merge 

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

func (*Addons) XXX_MessageName 

func (*Addons) XXX_MessageName() string

func (*Addons) XXX_Size 

func (m *Addons) XXX_Size() int

func (*Addons) XXX_Unmarshal 

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

type AuthConfig 

type AuthConfig struct {
	Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	PrivateSSHKey        string   `protobuf:"bytes,3,opt,name=privateSSHKey,proto3" json:"privateSSHKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AuthConfig) Descriptor 

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

func (*AuthConfig) Marshal 

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

func (*AuthConfig) MarshalTo 

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

func (*AuthConfig) ProtoMessage 

func (*AuthConfig) ProtoMessage()

func (*AuthConfig) Reset 

func (m *AuthConfig) Reset()

func (*AuthConfig) Size 

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

func (*AuthConfig) String 

func (m *AuthConfig) String() string

func (*AuthConfig) Unmarshal 

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

func (*AuthConfig) XXX_DiscardUnknown 

func (m *AuthConfig) XXX_DiscardUnknown()

func (*AuthConfig) XXX_Marshal 

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

func (*AuthConfig) XXX_Merge 

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

func (*AuthConfig) XXX_MessageName 

func (*AuthConfig) XXX_MessageName() string

func (*AuthConfig) XXX_Size 

func (m *AuthConfig) XXX_Size() int

func (*AuthConfig) XXX_Unmarshal 

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

type Cluster 

type Cluster struct {
	TimeoutMins          string     `protobuf:"bytes,1,opt,name=timeoutMins,proto3" json:"timeoutMins,omitempty"`
	ClusterType          string     `protobuf:"bytes,2,opt,name=clusterType,proto3" json:"clusterType,omitempty"`
	PodCIDR              string     `protobuf:"bytes,3,opt,name=podCIDR,proto3" json:"podCIDR,omitempty"`
	ServiceCIDR          string     `protobuf:"bytes,4,opt,name=serviceCIDR,proto3" json:"serviceCIDR,omitempty"`
	MasterList           []Node     `protobuf:"bytes,5,rep,name=masterList,proto3" json:"masterList"`
	ExternalLoadBalancer string     `protobuf:"bytes,6,opt,name=externalLoadBalancer,proto3" json:"externalLoadBalancer,omitempty"`
	NodeList             []Node     `protobuf:"bytes,7,rep,name=nodeList,proto3" json:"nodeList"`
	EtcdList             []Node     `protobuf:"bytes,8,rep,name=etcdList,proto3" json:"etcdList"`
	Region               string     `protobuf:"bytes,9,opt,name=region,proto3" json:"region,omitempty"`
	AuthConfig           AuthConfig `protobuf:"bytes,10,opt,name=authConfig,proto3" json:"authConfig"`
	KubeVersion          string     `protobuf:"bytes,11,opt,name=kubeVersion,proto3" json:"kubeVersion,omitempty"`
	ImagesRegistry       string     `protobuf:"bytes,12,opt,name=imagesRegistry,proto3" json:"imagesRegistry,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Cluster) Descriptor 

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

func (*Cluster) Marshal 

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

func (*Cluster) MarshalTo 

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

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset 

func (m *Cluster) Reset()

func (*Cluster) Size 

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

func (*Cluster) String 

func (m *Cluster) String() string

func (*Cluster) Unmarshal 

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

func (*Cluster) XXX_DiscardUnknown 

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal 

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

func (*Cluster) XXX_Merge 

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

func (*Cluster) XXX_MessageName 

func (*Cluster) XXX_MessageName() string

func (*Cluster) XXX_Size 

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal 

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

type Fields 

type Fields struct {
	// Map stores a set of fields in a data structure like a Trie.
	//
	// Each key is either a '.' representing the field itself, and will always map to an empty set,
	// or a string representing a sub-field or item. The string will follow one of these four formats:
	// 'f:<name>', where <name> is the name of a field in a struct, or key in a map
	// 'v:<value>', where <value> is the exact json formatted value of a list item
	// 'i:<index>', where <index> is position of a item in a list
	// 'k:<keys>', where <keys> is a map of  a list item's key fields to their unique values
	// If a key maps to an empty Fields value, the field that key represents is part of the set.
	//
	// The exact format is defined in k8s.io/apiserver/pkg/endpoints/handlers/fieldmanager/internal
	Map                  map[string]*Fields `` /* 147-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Fields stores a set of fields in a data structure like a Trie. To understand how this is used, see: https://github.com/kubernetes-sigs/structured-merge-diff

func (*Fields) Descriptor 

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

func (*Fields) Marshal 

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

func (*Fields) MarshalTo 

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

func (*Fields) ProtoMessage 

func (*Fields) ProtoMessage()

func (*Fields) Reset 

func (m *Fields) Reset()

func (*Fields) Size 

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

func (*Fields) String 

func (m *Fields) String() string

func (*Fields) Unmarshal 

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

func (*Fields) XXX_DiscardUnknown 

func (m *Fields) XXX_DiscardUnknown()

func (*Fields) XXX_Marshal 

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

func (*Fields) XXX_Merge 

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

func (*Fields) XXX_MessageName 

func (*Fields) XXX_MessageName() string

func (*Fields) XXX_Size 

func (m *Fields) XXX_Size() int

func (*Fields) XXX_Unmarshal 

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

type File 

type File struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Content              []byte   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*File) Descriptor 

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

func (*File) Marshal 

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

func (*File) MarshalTo 

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

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) Reset 

func (m *File) Reset()

func (*File) Size 

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

func (*File) String 

func (m *File) String() string

func (*File) Unmarshal 

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

func (*File) XXX_DiscardUnknown 

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal 

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

func (*File) XXX_Merge 

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

func (*File) XXX_MessageName 

func (*File) XXX_MessageName() string

func (*File) XXX_Size 

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal 

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

type InstallClusterResponse 

type InstallClusterResponse struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InstallClusterResponse) Descriptor 

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

func (*InstallClusterResponse) Marshal 

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

func (*InstallClusterResponse) MarshalTo 

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

func (*InstallClusterResponse) ProtoMessage 

func (*InstallClusterResponse) ProtoMessage()

func (*InstallClusterResponse) Reset 

func (m *InstallClusterResponse) Reset()

func (*InstallClusterResponse) Size 

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

func (*InstallClusterResponse) String 

func (m *InstallClusterResponse) String() string

func (*InstallClusterResponse) Unmarshal 

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

func (*InstallClusterResponse) XXX_DiscardUnknown 

func (m *InstallClusterResponse) XXX_DiscardUnknown()

func (*InstallClusterResponse) XXX_Marshal 

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

func (*InstallClusterResponse) XXX_Merge 

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

func (*InstallClusterResponse) XXX_MessageName 

func (*InstallClusterResponse) XXX_MessageName() string

func (*InstallClusterResponse) XXX_Size 

func (m *InstallClusterResponse) XXX_Size() int

func (*InstallClusterResponse) XXX_Unmarshal 

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

type InstallerClient 

type InstallerClient interface {
	// copy file
	CopyFile(ctx context.Context, in *File, opts ...grpc.CallOption) (Installer_CopyFileClient, error)
	// dispatch cluster config to all agent
	InstallCluster(ctx context.Context, in *KubernetesClusterRequest, opts ...grpc.CallOption) (*InstallClusterResponse, error)
}

InstallerClient is the client API for Installer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewInstallerClient 

func NewInstallerClient(cc *grpc.ClientConn) InstallerClient

type InstallerServer 

type InstallerServer interface {
	// copy file
	CopyFile(*File, Installer_CopyFileServer) error
	// dispatch cluster config to all agent
	InstallCluster(context.Context, *KubernetesClusterRequest) (*InstallClusterResponse, error)
}

InstallerServer is the server API for Installer service.

type Installer_CopyFileClient 

type Installer_CopyFileClient interface {
	Recv() (*File, error)
	grpc.ClientStream
}

type Installer_CopyFileServer 

type Installer_CopyFileServer interface {
	Send(*File) error
	grpc.ServerStream
}

type KubernetesClusterRequest 

type KubernetesClusterRequest struct {
	TypeMeta             `protobuf:"bytes,1,opt,name=typeMeta,proto3,embedded=typeMeta" json:"typeMeta"`
	ObjectMeta           `protobuf:"bytes,2,opt,name=objectMeta,proto3,embedded=objectMeta" json:"objectMeta"`
	Spec                 KubernetesClusterSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*KubernetesClusterRequest) Descriptor 

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

func (*KubernetesClusterRequest) Marshal 

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

func (*KubernetesClusterRequest) MarshalTo 

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

func (*KubernetesClusterRequest) ProtoMessage 

func (*KubernetesClusterRequest) ProtoMessage()

func (*KubernetesClusterRequest) Reset 

func (m *KubernetesClusterRequest) Reset()

func (*KubernetesClusterRequest) Size 

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

func (*KubernetesClusterRequest) String 

func (m *KubernetesClusterRequest) String() string

func (*KubernetesClusterRequest) Unmarshal 

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

func (*KubernetesClusterRequest) XXX_DiscardUnknown 

func (m *KubernetesClusterRequest) XXX_DiscardUnknown()

func (*KubernetesClusterRequest) XXX_Marshal 

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

func (*KubernetesClusterRequest) XXX_Merge 

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

func (*KubernetesClusterRequest) XXX_MessageName 

func (*KubernetesClusterRequest) XXX_MessageName() string

func (*KubernetesClusterRequest) XXX_Size 

func (m *KubernetesClusterRequest) XXX_Size() int

func (*KubernetesClusterRequest) XXX_Unmarshal 

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

type KubernetesClusterSpec 

type KubernetesClusterSpec struct {
	Cluster              Cluster  `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster"`
	Addons               Addons   `protobuf:"bytes,2,opt,name=addons,proto3" json:"addons"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KubernetesClusterSpec) Descriptor 

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

func (*KubernetesClusterSpec) Marshal 

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

func (*KubernetesClusterSpec) MarshalTo 

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

func (*KubernetesClusterSpec) ProtoMessage 

func (*KubernetesClusterSpec) ProtoMessage()

func (*KubernetesClusterSpec) Reset 

func (m *KubernetesClusterSpec) Reset()

func (*KubernetesClusterSpec) Size 

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

func (*KubernetesClusterSpec) String 

func (m *KubernetesClusterSpec) String() string

func (*KubernetesClusterSpec) Unmarshal 

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

func (*KubernetesClusterSpec) XXX_DiscardUnknown 

func (m *KubernetesClusterSpec) XXX_DiscardUnknown()

func (*KubernetesClusterSpec) XXX_Marshal 

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

func (*KubernetesClusterSpec) XXX_Merge 

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

func (*KubernetesClusterSpec) XXX_MessageName 

func (*KubernetesClusterSpec) XXX_MessageName() string

func (*KubernetesClusterSpec) XXX_Size 

func (m *KubernetesClusterSpec) XXX_Size() int

func (*KubernetesClusterSpec) XXX_Unmarshal 

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

type ManagedFieldsEntry 

type ManagedFieldsEntry struct {
	// Manager is an identifier of the workflow managing these fields.
	Manager string `protobuf:"bytes,1,opt,name=manager,proto3" json:"manager,omitempty"`
	// Operation is the type of operation which lead to this ManagedFieldsEntry being created.
	// The only valid values for this field are 'Apply' and 'Update'.
	Operation string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// APIVersion defines the version of this resource that this field set
	// applies to. The format is "group/version" just like the top-level
	// APIVersion field. It is necessary to track the version of a field
	// set because it cannot be automatically converted.
	ApiVersion string `protobuf:"bytes,3,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	// Time is timestamp of when these fields were set. It should always be empty if Operation is 'Apply'
	// +
	Time *Time `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// Fields identifies a set of fields.
	// +
	Fields               *Fields  `protobuf:"bytes,5,opt,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ManagedFieldsEntry is a workflow-id, a FieldSet and the group version of the resource that the fieldset applies to.

func (*ManagedFieldsEntry) Descriptor 

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

func (*ManagedFieldsEntry) Marshal 

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

func (*ManagedFieldsEntry) MarshalTo 

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

func (*ManagedFieldsEntry) ProtoMessage 

func (*ManagedFieldsEntry) ProtoMessage()

func (*ManagedFieldsEntry) Reset 

func (m *ManagedFieldsEntry) Reset()

func (*ManagedFieldsEntry) Size 

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

func (*ManagedFieldsEntry) String 

func (m *ManagedFieldsEntry) String() string

func (*ManagedFieldsEntry) Unmarshal 

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

func (*ManagedFieldsEntry) XXX_DiscardUnknown 

func (m *ManagedFieldsEntry) XXX_DiscardUnknown()

func (*ManagedFieldsEntry) XXX_Marshal 

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

func (*ManagedFieldsEntry) XXX_Merge 

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

func (*ManagedFieldsEntry) XXX_MessageName 

func (*ManagedFieldsEntry) XXX_MessageName() string

func (*ManagedFieldsEntry) XXX_Size 

func (m *ManagedFieldsEntry) XXX_Size() int

func (*ManagedFieldsEntry) XXX_Unmarshal 

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

type Node 

type Node struct {
	IP                   string   `protobuf:"bytes,1,opt,name=IP,proto3" json:"IP,omitempty"`
	Role                 string   `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Node) Descriptor 

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

func (*Node) Marshal 

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

func (*Node) MarshalTo 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

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

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

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

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_MessageName 

func (*Node) XXX_MessageName() string

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type ObjectMeta 

type ObjectMeta struct {
	Name                       string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	GenerateName               string              `protobuf:"bytes,2,opt,name=generateName,proto3" json:"generateName,omitempty"`
	Namespace                  string              `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	SelfLink                   string              `protobuf:"bytes,4,opt,name=selfLink,proto3" json:"selfLink,omitempty"`
	Uid                        string              `protobuf:"bytes,5,opt,name=uid,proto3" json:"uid,omitempty"`
	ResourceVersion            string              `protobuf:"bytes,6,opt,name=resourceVersion,proto3" json:"resourceVersion,omitempty"`
	Generation                 int64               `protobuf:"varint,7,opt,name=generation,proto3" json:"generation,omitempty"`
	CreationTimestamp          Time                `protobuf:"bytes,8,opt,name=creationTimestamp,proto3" json:"creationTimestamp"`
	DeletionTimestamp          *Time               `protobuf:"bytes,9,opt,name=deletionTimestamp,proto3" json:"deletionTimestamp,omitempty"`
	DeletionGracePeriodSeconds int64               `protobuf:"varint,10,opt,name=deletionGracePeriodSeconds,proto3" json:"deletionGracePeriodSeconds,omitempty"`
	Labels                     map[string]string   `` /* 154-byte string literal not displayed */
	Annotations                map[string]string   `` /* 164-byte string literal not displayed */
	OwnerReferences            []OwnerReference    `protobuf:"bytes,13,rep,name=ownerReferences,proto3" json:"ownerReferences"`
	Finalizers                 []string            `protobuf:"bytes,14,rep,name=finalizers,proto3" json:"finalizers,omitempty"`
	ClusterName                string              `protobuf:"bytes,15,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	ManagedFields              *ManagedFieldsEntry `protobuf:"bytes,17,opt,name=managedFields,proto3" json:"managedFields,omitempty"`
	XXX_NoUnkeyedLiteral       struct{}            `json:"-"`
	XXX_unrecognized           []byte              `json:"-"`
	XXX_sizecache              int32               `json:"-"`
}

ObjectMeta is metadata that all persisted resources must have, which includes all objects users must create.

func (*ObjectMeta) Descriptor 

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

func (*ObjectMeta) Marshal 

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

func (*ObjectMeta) MarshalTo 

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

func (*ObjectMeta) ProtoMessage 

func (*ObjectMeta) ProtoMessage()

func (*ObjectMeta) Reset 

func (m *ObjectMeta) Reset()

func (*ObjectMeta) Size 

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

func (*ObjectMeta) String 

func (m *ObjectMeta) String() string

func (*ObjectMeta) Unmarshal 

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

func (*ObjectMeta) XXX_DiscardUnknown 

func (m *ObjectMeta) XXX_DiscardUnknown()

func (*ObjectMeta) XXX_Marshal 

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

func (*ObjectMeta) XXX_Merge 

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

func (*ObjectMeta) XXX_MessageName 

func (*ObjectMeta) XXX_MessageName() string

func (*ObjectMeta) XXX_Size 

func (m *ObjectMeta) XXX_Size() int

func (*ObjectMeta) XXX_Unmarshal 

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

type OwnerReference 

type OwnerReference struct {
	// API version of the referent.
	ApiVersion string `protobuf:"bytes,5,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	// Kind of the referent.
	// More info: https://git.k8s.io/community/contributors/devel/api-conventions.md#types-kinds
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// Name of the referent.
	// More info: http://kubernetes.io/docs/user-guide/identifiers#names
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// UID of the referent.
	// More info: http://kubernetes.io/docs/user-guide/identifiers#uids
	Uid string `protobuf:"bytes,4,opt,name=uid,proto3" json:"uid,omitempty"`
	// If true, this reference points to the managing controller.
	// +
	Controller bool `protobuf:"varint,6,opt,name=controller,proto3" json:"controller,omitempty"`
	// If true, AND if the owner has the "foregroundDeletion" finalizer, then
	// the owner cannot be deleted from the key-value store until this
	// reference is removed.
	// Defaults to false.
	// To set this field, a user needs "delete" permission of the owner,
	// otherwise 422 (Unprocessable Entity) will be returned.
	// +
	BlockOwnerDeletion   bool     `protobuf:"varint,7,opt,name=blockOwnerDeletion,proto3" json:"blockOwnerDeletion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

OwnerReference contains enough information to let you identify an owning object. An owning object must be in the same namespace as the dependent, or be cluster-scoped, so there is no namespace field.

func (*OwnerReference) Descriptor 

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

func (*OwnerReference) Marshal 

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

func (*OwnerReference) MarshalTo 

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

func (*OwnerReference) ProtoMessage 

func (*OwnerReference) ProtoMessage()

func (*OwnerReference) Reset 

func (m *OwnerReference) Reset()

func (*OwnerReference) Size 

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

func (*OwnerReference) String 

func (m *OwnerReference) String() string

func (*OwnerReference) Unmarshal 

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

func (*OwnerReference) XXX_DiscardUnknown 

func (m *OwnerReference) XXX_DiscardUnknown()

func (*OwnerReference) XXX_Marshal 

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

func (*OwnerReference) XXX_Merge 

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

func (*OwnerReference) XXX_MessageName 

func (*OwnerReference) XXX_MessageName() string

func (*OwnerReference) XXX_Size 

func (m *OwnerReference) XXX_Size() int

func (*OwnerReference) XXX_Unmarshal 

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

type Time 

type Time struct {
	// Represents seconds of UTC time since Unix epoch
	// 1970-01-01T00:00:00Z. Must be from 0001-01-01T00:00:00Z to
	// 9999-12-31T23:59:59Z inclusive.
	Seconds int64 `protobuf:"varint,1,opt,name=seconds,proto3" json:"seconds,omitempty"`
	// Non-negative fractions of a second at nanosecond resolution. Negative
	// second values with fractions must still have non-negative nanos values
	// that count forward in time. Must be from 0 to 999,999,999
	// inclusive. This field may be limited in precision depending on context.
	Nanos                int32    `protobuf:"varint,2,opt,name=nanos,proto3" json:"nanos,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Time is a wrapper around time.Time which supports correct marshaling to YAML and JSON. Wrappers are provided for many of the factory methods that the time package offers.

+protobuf.options.marshal=false +protobuf.as=Timestamp +protobuf.options.(gogoproto.goproto_stringer)=false

func (*Time) Descriptor 

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

func (*Time) Marshal 

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

func (*Time) MarshalTo 

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

func (*Time) ProtoMessage 

func (*Time) ProtoMessage()

func (*Time) Reset 

func (m *Time) Reset()

func (*Time) Size 

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

func (*Time) String 

func (m *Time) String() string

func (*Time) Unmarshal 

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

func (*Time) XXX_DiscardUnknown 

func (m *Time) XXX_DiscardUnknown()

func (*Time) XXX_Marshal 

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

func (*Time) XXX_Merge 

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

func (*Time) XXX_MessageName 

func (*Time) XXX_MessageName() string

func (*Time) XXX_Size 

func (m *Time) XXX_Size() int

func (*Time) XXX_Unmarshal 

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

type TypeMeta 

type TypeMeta struct {
	Kind                 string   `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	APIVersion           string   `protobuf:"bytes,2,opt,name=APIVersion,proto3" json:"APIVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TypeMeta) Descriptor 

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

func (*TypeMeta) Marshal 

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

func (*TypeMeta) MarshalTo 

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

func (*TypeMeta) ProtoMessage 

func (*TypeMeta) ProtoMessage()

func (*TypeMeta) Reset 

func (m *TypeMeta) Reset()

func (*TypeMeta) Size 

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

func (*TypeMeta) String 

func (m *TypeMeta) String() string

func (*TypeMeta) Unmarshal 

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

func (*TypeMeta) XXX_DiscardUnknown 

func (m *TypeMeta) XXX_DiscardUnknown()

func (*TypeMeta) XXX_Marshal 

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

func (*TypeMeta) XXX_Merge 

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

func (*TypeMeta) XXX_MessageName 

func (*TypeMeta) XXX_MessageName() string

func (*TypeMeta) XXX_Size 

func (m *TypeMeta) XXX_Size() int

func (*TypeMeta) XXX_Unmarshal 

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

type UnimplementedInstallerServer 

type UnimplementedInstallerServer struct {
}

UnimplementedInstallerServer can be embedded to have forward compatible implementations.

func (*UnimplementedInstallerServer) CopyFile 

func (*UnimplementedInstallerServer) CopyFile(req *File, srv Installer_CopyFileServer) error

func (*UnimplementedInstallerServer) InstallCluster 

func (*UnimplementedInstallerServer) InstallCluster(ctx context.Context, req *KubernetesClusterRequest) (*InstallClusterResponse, 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.