proto

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package proto is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSkaffoldServiceHandler 

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

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

func RegisterSkaffoldServiceHandlerClient 

func RegisterSkaffoldServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SkaffoldServiceClient) error

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

func RegisterSkaffoldServiceHandlerFromEndpoint 

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

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

func RegisterSkaffoldServiceServer 

func RegisterSkaffoldServiceServer(s *grpc.Server, srv SkaffoldServiceServer)

Types

type BuildEvent 

type BuildEvent struct {
	Artifact             string   `protobuf:"bytes,1,opt,name=artifact,proto3" json:"artifact,omitempty"`
	Status               string   `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Err                  string   `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

`BuildEvent` describes the build status per artifact, and will be emitted by Skaffold anytime a build starts or finishes, successfully or not. If the build fails, an error will be attached to the event.

func (*BuildEvent) Descriptor 

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

func (*BuildEvent) GetArtifact 

func (m *BuildEvent) GetArtifact() string

func (*BuildEvent) GetErr 

func (m *BuildEvent) GetErr() string

func (*BuildEvent) GetStatus 

func (m *BuildEvent) GetStatus() string

func (*BuildEvent) ProtoMessage 

func (*BuildEvent) ProtoMessage()

func (*BuildEvent) Reset 

func (m *BuildEvent) Reset()

func (*BuildEvent) String 

func (m *BuildEvent) String() string

func (*BuildEvent) XXX_DiscardUnknown 

func (m *BuildEvent) XXX_DiscardUnknown()

func (*BuildEvent) XXX_Marshal 

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

func (*BuildEvent) XXX_Merge 

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

func (*BuildEvent) XXX_Size 

func (m *BuildEvent) XXX_Size() int

func (*BuildEvent) XXX_Unmarshal 

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

type BuildState 

type BuildState struct {
	// A map of `artifact name -> build-state`.
	// Artifact name is defined in the `skaffold.yaml`.
	// The `build-state` can be: <br>
	// - `"Not started"`: not yet started <br>
	// - `"In progress"`: build started <br>
	// - `"Complete"`: build succeeded <br>
	// - `"Failed"`: build failed
	Artifacts            map[string]string `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

`BuildState` maps Skaffold artifacts to their current build states

func (*BuildState) Descriptor 

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

func (*BuildState) GetArtifacts 

func (m *BuildState) GetArtifacts() map[string]string

func (*BuildState) ProtoMessage 

func (*BuildState) ProtoMessage()

func (*BuildState) Reset 

func (m *BuildState) Reset()

func (*BuildState) String 

func (m *BuildState) String() string

func (*BuildState) XXX_DiscardUnknown 

func (m *BuildState) XXX_DiscardUnknown()

func (*BuildState) XXX_Marshal 

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

func (*BuildState) XXX_Merge 

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

func (*BuildState) XXX_Size 

func (m *BuildState) XXX_Size() int

func (*BuildState) XXX_Unmarshal 

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

type DebuggingContainerEvent added in v1.3.1 

type DebuggingContainerEvent struct {
	Status               string            `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	PodName              string            `protobuf:"bytes,2,opt,name=podName,proto3" json:"podName,omitempty"`
	ContainerName        string            `protobuf:"bytes,3,opt,name=containerName,proto3" json:"containerName,omitempty"`
	Namespace            string            `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Artifact             string            `protobuf:"bytes,5,opt,name=artifact,proto3" json:"artifact,omitempty"`
	Runtime              string            `protobuf:"bytes,6,opt,name=runtime,proto3" json:"runtime,omitempty"`
	WorkingDir           string            `protobuf:"bytes,7,opt,name=workingDir,proto3" json:"workingDir,omitempty"`
	DebugPorts           map[string]uint32 `` /* 162-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

DebuggingContainerEvent is raised when a debugging container is started or terminated

func (*DebuggingContainerEvent) Descriptor added in v1.3.1 

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

func (*DebuggingContainerEvent) GetArtifact added in v1.4.0 

func (m *DebuggingContainerEvent) GetArtifact() string

func (*DebuggingContainerEvent) GetContainerName added in v1.3.1 

func (m *DebuggingContainerEvent) GetContainerName() string

func (*DebuggingContainerEvent) GetDebugPorts added in v1.3.1 

func (m *DebuggingContainerEvent) GetDebugPorts() map[string]uint32

func (*DebuggingContainerEvent) GetNamespace added in v1.3.1 

func (m *DebuggingContainerEvent) GetNamespace() string

func (*DebuggingContainerEvent) GetPodName added in v1.3.1 

func (m *DebuggingContainerEvent) GetPodName() string

func (*DebuggingContainerEvent) GetRuntime added in v1.3.1 

func (m *DebuggingContainerEvent) GetRuntime() string

func (*DebuggingContainerEvent) GetStatus added in v1.3.1 

func (m *DebuggingContainerEvent) GetStatus() string

func (*DebuggingContainerEvent) GetWorkingDir added in v1.3.1 

func (m *DebuggingContainerEvent) GetWorkingDir() string

func (*DebuggingContainerEvent) ProtoMessage added in v1.3.1 

func (*DebuggingContainerEvent) ProtoMessage()

func (*DebuggingContainerEvent) Reset added in v1.3.1 

func (m *DebuggingContainerEvent) Reset()

func (*DebuggingContainerEvent) String added in v1.3.1 

func (m *DebuggingContainerEvent) String() string

func (*DebuggingContainerEvent) XXX_DiscardUnknown added in v1.3.1 

func (m *DebuggingContainerEvent) XXX_DiscardUnknown()

func (*DebuggingContainerEvent) XXX_Marshal added in v1.3.1 

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

func (*DebuggingContainerEvent) XXX_Merge added in v1.3.1 

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

func (*DebuggingContainerEvent) XXX_Size added in v1.3.1 

func (m *DebuggingContainerEvent) XXX_Size() int

func (*DebuggingContainerEvent) XXX_Unmarshal added in v1.3.1 

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

type DeployEvent 

type DeployEvent struct {
	Status               string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Err                  string   `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

`DeployEvent` represents the status of a deployment, and is emitted by Skaffold anytime a deployment starts or completes, successfully or not.

func (*DeployEvent) Descriptor 

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

func (*DeployEvent) GetErr 

func (m *DeployEvent) GetErr() string

func (*DeployEvent) GetStatus 

func (m *DeployEvent) GetStatus() string

func (*DeployEvent) ProtoMessage 

func (*DeployEvent) ProtoMessage()

func (*DeployEvent) Reset 

func (m *DeployEvent) Reset()

func (*DeployEvent) String 

func (m *DeployEvent) String() string

func (*DeployEvent) XXX_DiscardUnknown 

func (m *DeployEvent) XXX_DiscardUnknown()

func (*DeployEvent) XXX_Marshal 

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

func (*DeployEvent) XXX_Merge 

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

func (*DeployEvent) XXX_Size 

func (m *DeployEvent) XXX_Size() int

func (*DeployEvent) XXX_Unmarshal 

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

type DeployState 

type DeployState struct {
	Status               string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

`DeployState` describes the status of the current deploy

func (*DeployState) Descriptor 

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

func (*DeployState) GetStatus 

func (m *DeployState) GetStatus() string

func (*DeployState) ProtoMessage 

func (*DeployState) ProtoMessage()

func (*DeployState) Reset 

func (m *DeployState) Reset()

func (*DeployState) String 

func (m *DeployState) String() string

func (*DeployState) XXX_DiscardUnknown 

func (m *DeployState) XXX_DiscardUnknown()

func (*DeployState) XXX_Marshal 

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

func (*DeployState) XXX_Merge 

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

func (*DeployState) XXX_Size 

func (m *DeployState) XXX_Size() int

func (*DeployState) XXX_Unmarshal 

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

type Event 

type Event struct {
	// Types that are valid to be assigned to EventType:
	//	*Event_MetaEvent
	//	*Event_BuildEvent
	//	*Event_DeployEvent
	//	*Event_PortEvent
	//	*Event_StatusCheckEvent
	//	*Event_ResourceStatusCheckEvent
	//	*Event_FileSyncEvent
	//	*Event_DebuggingContainerEvent
	EventType            isEvent_EventType `protobuf_oneof:"event_type"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

`Event` describes an event in the Skaffold process. It is one of MetaEvent, BuildEvent, DeployEvent, PortEvent, StatusCheckEvent, ResourceStatusCheckEvent, FileSyncEvent, or DebuggingContainerEvent.

func (*Event) Descriptor 

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

func (*Event) GetBuildEvent 

func (m *Event) GetBuildEvent() *BuildEvent

func (*Event) GetDebuggingContainerEvent added in v1.3.1 

func (m *Event) GetDebuggingContainerEvent() *DebuggingContainerEvent

func (*Event) GetDeployEvent 

func (m *Event) GetDeployEvent() *DeployEvent

func (*Event) GetEventType 

func (m *Event) GetEventType() isEvent_EventType

func (*Event) GetFileSyncEvent added in v0.40.0 

func (m *Event) GetFileSyncEvent() *FileSyncEvent

func (*Event) GetMetaEvent 

func (m *Event) GetMetaEvent() *MetaEvent

func (*Event) GetPortEvent 

func (m *Event) GetPortEvent() *PortEvent

func (*Event) GetResourceStatusCheckEvent added in v0.39.0 

func (m *Event) GetResourceStatusCheckEvent() *ResourceStatusCheckEvent

func (*Event) GetStatusCheckEvent added in v0.39.0 

func (m *Event) GetStatusCheckEvent() *StatusCheckEvent

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_OneofWrappers 

func (*Event) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type Event_BuildEvent 

type Event_BuildEvent struct {
	BuildEvent *BuildEvent `protobuf:"bytes,2,opt,name=buildEvent,proto3,oneof"`
}

type Event_DebuggingContainerEvent added in v1.3.1 

type Event_DebuggingContainerEvent struct {
	DebuggingContainerEvent *DebuggingContainerEvent `protobuf:"bytes,8,opt,name=debuggingContainerEvent,proto3,oneof"`
}

type Event_DeployEvent 

type Event_DeployEvent struct {
	DeployEvent *DeployEvent `protobuf:"bytes,3,opt,name=deployEvent,proto3,oneof"`
}

type Event_FileSyncEvent added in v0.40.0 

type Event_FileSyncEvent struct {
	FileSyncEvent *FileSyncEvent `protobuf:"bytes,7,opt,name=fileSyncEvent,proto3,oneof"`
}

type Event_MetaEvent 

type Event_MetaEvent struct {
	MetaEvent *MetaEvent `protobuf:"bytes,1,opt,name=metaEvent,proto3,oneof"`
}

type Event_PortEvent 

type Event_PortEvent struct {
	PortEvent *PortEvent `protobuf:"bytes,4,opt,name=portEvent,proto3,oneof"`
}

type Event_ResourceStatusCheckEvent added in v0.39.0 

type Event_ResourceStatusCheckEvent struct {
	ResourceStatusCheckEvent *ResourceStatusCheckEvent `protobuf:"bytes,6,opt,name=resourceStatusCheckEvent,proto3,oneof"`
}

type Event_StatusCheckEvent added in v0.39.0 

type Event_StatusCheckEvent struct {
	StatusCheckEvent *StatusCheckEvent `protobuf:"bytes,5,opt,name=statusCheckEvent,proto3,oneof"`
}

type FileSyncEvent added in v0.40.0 

type FileSyncEvent struct {
	FileCount            int32    `protobuf:"varint,1,opt,name=fileCount,proto3" json:"fileCount,omitempty"`
	Image                string   `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Status               string   `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Err                  string   `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FileSyncEvent describes the sync status.

func (*FileSyncEvent) Descriptor added in v0.40.0 

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

func (*FileSyncEvent) GetErr added in v0.40.0 

func (m *FileSyncEvent) GetErr() string

func (*FileSyncEvent) GetFileCount added in v0.40.0 

func (m *FileSyncEvent) GetFileCount() int32

func (*FileSyncEvent) GetImage added in v0.40.0 

func (m *FileSyncEvent) GetImage() string

func (*FileSyncEvent) GetStatus added in v0.40.0 

func (m *FileSyncEvent) GetStatus() string

func (*FileSyncEvent) ProtoMessage added in v0.40.0 

func (*FileSyncEvent) ProtoMessage()

func (*FileSyncEvent) Reset added in v0.40.0 

func (m *FileSyncEvent) Reset()

func (*FileSyncEvent) String added in v0.40.0 

func (m *FileSyncEvent) String() string

func (*FileSyncEvent) XXX_DiscardUnknown added in v0.40.0 

func (m *FileSyncEvent) XXX_DiscardUnknown()

func (*FileSyncEvent) XXX_Marshal added in v0.40.0 

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

func (*FileSyncEvent) XXX_Merge added in v0.40.0 

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

func (*FileSyncEvent) XXX_Size added in v0.40.0 

func (m *FileSyncEvent) XXX_Size() int

func (*FileSyncEvent) XXX_Unmarshal added in v0.40.0 

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

type FileSyncState added in v0.40.0 

type FileSyncState struct {
	Status               string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

`FileSyncState` contains the status of the current file sync

func (*FileSyncState) Descriptor added in v0.40.0 

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

func (*FileSyncState) GetStatus added in v0.40.0 

func (m *FileSyncState) GetStatus() string

func (*FileSyncState) ProtoMessage added in v0.40.0 

func (*FileSyncState) ProtoMessage()

func (*FileSyncState) Reset added in v0.40.0 

func (m *FileSyncState) Reset()

func (*FileSyncState) String added in v0.40.0 

func (m *FileSyncState) String() string

func (*FileSyncState) XXX_DiscardUnknown added in v0.40.0 

func (m *FileSyncState) XXX_DiscardUnknown()

func (*FileSyncState) XXX_Marshal added in v0.40.0 

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

func (*FileSyncState) XXX_Merge added in v0.40.0 

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

func (*FileSyncState) XXX_Size added in v0.40.0 

func (m *FileSyncState) XXX_Size() int

func (*FileSyncState) XXX_Unmarshal added in v0.40.0 

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

type Intent added in v0.34.1 

type Intent struct {
	Build                bool     `protobuf:"varint,1,opt,name=build,proto3" json:"build,omitempty"`
	Sync                 bool     `protobuf:"varint,2,opt,name=sync,proto3" json:"sync,omitempty"`
	Deploy               bool     `protobuf:"varint,3,opt,name=deploy,proto3" json:"deploy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Intent represents user intents for a given phase to be unblocked, once.

func (*Intent) Descriptor added in v0.34.1 

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

func (*Intent) GetBuild added in v0.34.1 

func (m *Intent) GetBuild() bool

func (*Intent) GetDeploy added in v0.34.1 

func (m *Intent) GetDeploy() bool

func (*Intent) GetSync added in v0.34.1 

func (m *Intent) GetSync() bool

func (*Intent) ProtoMessage added in v0.34.1 

func (*Intent) ProtoMessage()

func (*Intent) Reset added in v0.34.1 

func (m *Intent) Reset()

func (*Intent) String added in v0.34.1 

func (m *Intent) String() string

func (*Intent) XXX_DiscardUnknown added in v0.34.1 

func (m *Intent) XXX_DiscardUnknown()

func (*Intent) XXX_Marshal added in v0.34.1 

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

func (*Intent) XXX_Merge added in v0.34.1 

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

func (*Intent) XXX_Size added in v0.34.1 

func (m *Intent) XXX_Size() int

func (*Intent) XXX_Unmarshal added in v0.34.1 

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

type LogEntry 

type LogEntry struct {
	Timestamp            *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Event                *Event               `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	Entry                string               `protobuf:"bytes,3,opt,name=entry,proto3" json:"entry,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

LogEntry describes an event and a string description of the event.

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetEntry 

func (m *LogEntry) GetEntry() string

func (*LogEntry) GetEvent 

func (m *LogEntry) GetEvent() *Event

func (*LogEntry) GetTimestamp 

func (m *LogEntry) GetTimestamp() *timestamp.Timestamp

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

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

func (*LogEntry) XXX_Merge 

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

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

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

type MetaEvent 

type MetaEvent struct {
	// entry, for example: `"Starting Skaffold: {Version:v0.39.0-16-g5bb7c9e0 ConfigVersion:skaffold/v1 GitVersion: GitCommit:5bb7c9e078e4d522a5ffc42a2f1274fd17d75902 GitTreeState:dirty BuildDate01:29Z GoVersion:go1.13rc1 Compiler:gc Platform:linux/amd64}"`
	Entry                string   `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

`MetaEvent` provides general information regarding Skaffold

func (*MetaEvent) Descriptor 

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

func (*MetaEvent) GetEntry 

func (m *MetaEvent) GetEntry() string

func (*MetaEvent) ProtoMessage 

func (*MetaEvent) ProtoMessage()

func (*MetaEvent) Reset 

func (m *MetaEvent) Reset()

func (*MetaEvent) String 

func (m *MetaEvent) String() string

func (*MetaEvent) XXX_DiscardUnknown 

func (m *MetaEvent) XXX_DiscardUnknown()

func (*MetaEvent) XXX_Marshal 

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

func (*MetaEvent) XXX_Merge 

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

func (*MetaEvent) XXX_Size 

func (m *MetaEvent) XXX_Size() int

func (*MetaEvent) XXX_Unmarshal 

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

type PortEvent 

type PortEvent struct {
	LocalPort            int32    `protobuf:"varint,1,opt,name=localPort,proto3" json:"localPort,omitempty"`
	RemotePort           int32    `protobuf:"varint,2,opt,name=remotePort,proto3" json:"remotePort,omitempty"`
	PodName              string   `protobuf:"bytes,3,opt,name=podName,proto3" json:"podName,omitempty"`
	ContainerName        string   `protobuf:"bytes,4,opt,name=containerName,proto3" json:"containerName,omitempty"`
	Namespace            string   `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PortName             string   `protobuf:"bytes,6,opt,name=portName,proto3" json:"portName,omitempty"`
	ResourceType         string   `protobuf:"bytes,7,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	ResourceName         string   `protobuf:"bytes,8,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	Address              string   `protobuf:"bytes,9,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PortEvent Event describes each port forwarding event.

func (*PortEvent) Descriptor 

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

func (*PortEvent) GetAddress added in v1.1.0 

func (m *PortEvent) GetAddress() string

func (*PortEvent) GetContainerName 

func (m *PortEvent) GetContainerName() string

func (*PortEvent) GetLocalPort 

func (m *PortEvent) GetLocalPort() int32

func (*PortEvent) GetNamespace 

func (m *PortEvent) GetNamespace() string

func (*PortEvent) GetPodName 

func (m *PortEvent) GetPodName() string

func (*PortEvent) GetPortName 

func (m *PortEvent) GetPortName() string

func (*PortEvent) GetRemotePort 

func (m *PortEvent) GetRemotePort() int32

func (*PortEvent) GetResourceName 

func (m *PortEvent) GetResourceName() string

func (*PortEvent) GetResourceType 

func (m *PortEvent) GetResourceType() string

func (*PortEvent) ProtoMessage 

func (*PortEvent) ProtoMessage()

func (*PortEvent) Reset 

func (m *PortEvent) Reset()

func (*PortEvent) String 

func (m *PortEvent) String() string

func (*PortEvent) XXX_DiscardUnknown 

func (m *PortEvent) XXX_DiscardUnknown()

func (*PortEvent) XXX_Marshal 

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

func (*PortEvent) XXX_Merge 

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

func (*PortEvent) XXX_Size 

func (m *PortEvent) XXX_Size() int

func (*PortEvent) XXX_Unmarshal 

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

type Request 

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

func (*Request) Descriptor 

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

func (*Request) GetName 

func (m *Request) GetName() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type ResourceStatusCheckEvent added in v0.39.0 

type ResourceStatusCheckEvent struct {
	Resource             string   `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Status               string   `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Message              string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Err                  string   `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A Resource StatusCheck Event, indicates progress for each kubernetes deployment. For every resource, there will be exactly one event with `status` *Succeeded* or *Failed* event. There can be multiple events with `status` *Pending*. Skaffold polls for resource status every 0.5 second. If the resource status changes, an event with `status` “Pending”, “Complete” and “Failed” will be sent with the new status.

func (*ResourceStatusCheckEvent) Descriptor added in v0.39.0 

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

func (*ResourceStatusCheckEvent) GetErr added in v0.39.0 

func (m *ResourceStatusCheckEvent) GetErr() string

func (*ResourceStatusCheckEvent) GetMessage added in v0.39.0 

func (m *ResourceStatusCheckEvent) GetMessage() string

func (*ResourceStatusCheckEvent) GetResource added in v0.39.0 

func (m *ResourceStatusCheckEvent) GetResource() string

func (*ResourceStatusCheckEvent) GetStatus added in v0.39.0 

func (m *ResourceStatusCheckEvent) GetStatus() string

func (*ResourceStatusCheckEvent) ProtoMessage added in v0.39.0 

func (*ResourceStatusCheckEvent) ProtoMessage()

func (*ResourceStatusCheckEvent) Reset added in v0.39.0 

func (m *ResourceStatusCheckEvent) Reset()

func (*ResourceStatusCheckEvent) String added in v0.39.0 

func (m *ResourceStatusCheckEvent) String() string

func (*ResourceStatusCheckEvent) XXX_DiscardUnknown added in v0.39.0 

func (m *ResourceStatusCheckEvent) XXX_DiscardUnknown()

func (*ResourceStatusCheckEvent) XXX_Marshal added in v0.39.0 

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

func (*ResourceStatusCheckEvent) XXX_Merge added in v0.39.0 

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

func (*ResourceStatusCheckEvent) XXX_Size added in v0.39.0 

func (m *ResourceStatusCheckEvent) XXX_Size() int

func (*ResourceStatusCheckEvent) XXX_Unmarshal added in v0.39.0 

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

type Response 

type Response struct {
	Msg                  string   `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetMsg 

func (m *Response) GetMsg() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type SkaffoldServiceClient 

type SkaffoldServiceClient interface {
	// Returns the state of the current Skaffold execution
	GetState(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*State, error)
	// DEPRECATED. Events should be used instead.
	// TODO remove (https://github.com/GoogleContainerTools/skaffold/issues/3168)
	EventLog(ctx context.Context, opts ...grpc.CallOption) (SkaffoldService_EventLogClient, error)
	// Returns all the events of the current Skaffold execution from the start
	Events(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (SkaffoldService_EventsClient, error)
	// Allows for a single execution of some or all of the phases (build, sync, deploy) in case autoBuild, autoDeploy or autoSync are disabled.
	Execute(ctx context.Context, in *UserIntentRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// EXPERIMENTAL. It allows for custom events to be implemented in custom builders for example.
	Handle(ctx context.Context, in *Event, opts ...grpc.CallOption) (*empty.Empty, error)
}

SkaffoldServiceClient is the client API for SkaffoldService service.

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

func NewSkaffoldServiceClient 

func NewSkaffoldServiceClient(cc *grpc.ClientConn) SkaffoldServiceClient

type SkaffoldServiceServer 

type SkaffoldServiceServer interface {
	// Returns the state of the current Skaffold execution
	GetState(context.Context, *empty.Empty) (*State, error)
	// DEPRECATED. Events should be used instead.
	// TODO remove (https://github.com/GoogleContainerTools/skaffold/issues/3168)
	EventLog(SkaffoldService_EventLogServer) error
	// Returns all the events of the current Skaffold execution from the start
	Events(*empty.Empty, SkaffoldService_EventsServer) error
	// Allows for a single execution of some or all of the phases (build, sync, deploy) in case autoBuild, autoDeploy or autoSync are disabled.
	Execute(context.Context, *UserIntentRequest) (*empty.Empty, error)
	// EXPERIMENTAL. It allows for custom events to be implemented in custom builders for example.
	Handle(context.Context, *Event) (*empty.Empty, error)
}

SkaffoldServiceServer is the server API for SkaffoldService service.

type SkaffoldService_EventLogClient 

type SkaffoldService_EventLogClient interface {
	Send(*LogEntry) error
	Recv() (*LogEntry, error)
	grpc.ClientStream
}

type SkaffoldService_EventLogServer 

type SkaffoldService_EventLogServer interface {
	Send(*LogEntry) error
	Recv() (*LogEntry, error)
	grpc.ServerStream
}

type SkaffoldService_EventsClient 

type SkaffoldService_EventsClient interface {
	Recv() (*LogEntry, error)
	grpc.ClientStream
}

type SkaffoldService_EventsServer 

type SkaffoldService_EventsServer interface {
	Send(*LogEntry) error
	grpc.ServerStream
}

type State 

type State struct {
	BuildState           *BuildState                `protobuf:"bytes,1,opt,name=buildState,proto3" json:"buildState,omitempty"`
	DeployState          *DeployState               `protobuf:"bytes,2,opt,name=deployState,proto3" json:"deployState,omitempty"`
	ForwardedPorts       map[int32]*PortEvent       `` /* 170-byte string literal not displayed */
	StatusCheckState     *StatusCheckState          `protobuf:"bytes,5,opt,name=statusCheckState,proto3" json:"statusCheckState,omitempty"`
	FileSyncState        *FileSyncState             `protobuf:"bytes,6,opt,name=fileSyncState,proto3" json:"fileSyncState,omitempty"`
	DebuggingContainers  []*DebuggingContainerEvent `protobuf:"bytes,7,rep,name=debuggingContainers,proto3" json:"debuggingContainers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

`State` represents the current state of the Skaffold components

func (*State) Descriptor 

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

func (*State) GetBuildState 

func (m *State) GetBuildState() *BuildState

func (*State) GetDebuggingContainers added in v1.3.1 

func (m *State) GetDebuggingContainers() []*DebuggingContainerEvent

func (*State) GetDeployState 

func (m *State) GetDeployState() *DeployState

func (*State) GetFileSyncState added in v0.40.0 

func (m *State) GetFileSyncState() *FileSyncState

func (*State) GetForwardedPorts 

func (m *State) GetForwardedPorts() map[int32]*PortEvent

func (*State) GetStatusCheckState added in v0.39.0 

func (m *State) GetStatusCheckState() *StatusCheckState

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) Reset 

func (m *State) Reset()

func (*State) String 

func (m *State) String() string

func (*State) XXX_DiscardUnknown 

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal 

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

func (*State) XXX_Merge 

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

func (*State) XXX_Size 

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal 

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

type StateResponse 

type StateResponse struct {
	State                *State   `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StateResponse) Descriptor 

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

func (*StateResponse) GetState 

func (m *StateResponse) GetState() *State

func (*StateResponse) ProtoMessage 

func (*StateResponse) ProtoMessage()

func (*StateResponse) Reset 

func (m *StateResponse) Reset()

func (*StateResponse) String 

func (m *StateResponse) String() string

func (*StateResponse) XXX_DiscardUnknown 

func (m *StateResponse) XXX_DiscardUnknown()

func (*StateResponse) XXX_Marshal 

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

func (*StateResponse) XXX_Merge 

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

func (*StateResponse) XXX_Size 

func (m *StateResponse) XXX_Size() int

func (*StateResponse) XXX_Unmarshal 

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

type StatusCheckEvent added in v0.39.0 

type StatusCheckEvent struct {
	Status               string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Err                  string   `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

`StatusCheckEvent` describes if the status check for kubernetes rollout has started, is in progress, has succeeded or failed.

func (*StatusCheckEvent) Descriptor added in v0.39.0 

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

func (*StatusCheckEvent) GetErr added in v0.39.0 

func (m *StatusCheckEvent) GetErr() string

func (*StatusCheckEvent) GetMessage added in v0.39.0 

func (m *StatusCheckEvent) GetMessage() string

func (*StatusCheckEvent) GetStatus added in v0.39.0 

func (m *StatusCheckEvent) GetStatus() string

func (*StatusCheckEvent) ProtoMessage added in v0.39.0 

func (*StatusCheckEvent) ProtoMessage()

func (*StatusCheckEvent) Reset added in v0.39.0 

func (m *StatusCheckEvent) Reset()

func (*StatusCheckEvent) String added in v0.39.0 

func (m *StatusCheckEvent) String() string

func (*StatusCheckEvent) XXX_DiscardUnknown added in v0.39.0 

func (m *StatusCheckEvent) XXX_DiscardUnknown()

func (*StatusCheckEvent) XXX_Marshal added in v0.39.0 

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

func (*StatusCheckEvent) XXX_Merge added in v0.39.0 

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

func (*StatusCheckEvent) XXX_Size added in v0.39.0 

func (m *StatusCheckEvent) XXX_Size() int

func (*StatusCheckEvent) XXX_Unmarshal added in v0.39.0 

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

type StatusCheckState added in v0.39.0 

type StatusCheckState struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// A map of `resource name -> status-check-state`. Where `resource-name` is the kubernetes resource name.
	// The `status-check-state` can be <br>
	// - `"Not started"`: indicates that `status-check` has just started. <br>
	// - `"In progress"`: InProgress is sent after every resource check is complete. <br>
	// - `"Succeeded"`:
	// - `"Failed"`:
	Resources            map[string]string `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

`StatusCheckState` describes the state of status check of current deployed resources.

func (*StatusCheckState) Descriptor added in v0.39.0 

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

func (*StatusCheckState) GetResources added in v0.40.0 

func (m *StatusCheckState) GetResources() map[string]string

func (*StatusCheckState) GetStatus added in v0.39.0 

func (m *StatusCheckState) GetStatus() string

func (*StatusCheckState) ProtoMessage added in v0.39.0 

func (*StatusCheckState) ProtoMessage()

func (*StatusCheckState) Reset added in v0.39.0 

func (m *StatusCheckState) Reset()

func (*StatusCheckState) String added in v0.39.0 

func (m *StatusCheckState) String() string

func (*StatusCheckState) XXX_DiscardUnknown added in v0.39.0 

func (m *StatusCheckState) XXX_DiscardUnknown()

func (*StatusCheckState) XXX_Marshal added in v0.39.0 

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

func (*StatusCheckState) XXX_Merge added in v0.39.0 

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

func (*StatusCheckState) XXX_Size added in v0.39.0 

func (m *StatusCheckState) XXX_Size() int

func (*StatusCheckState) XXX_Unmarshal added in v0.39.0 

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

type UnimplementedSkaffoldServiceServer 

type UnimplementedSkaffoldServiceServer struct {
}

UnimplementedSkaffoldServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSkaffoldServiceServer) EventLog 

func (*UnimplementedSkaffoldServiceServer) EventLog(srv SkaffoldService_EventLogServer) error

func (*UnimplementedSkaffoldServiceServer) Events 

func (*UnimplementedSkaffoldServiceServer) Events(req *empty.Empty, srv SkaffoldService_EventsServer) error

func (*UnimplementedSkaffoldServiceServer) Execute added in v0.34.1 

func (*UnimplementedSkaffoldServiceServer) Execute(ctx context.Context, req *UserIntentRequest) (*empty.Empty, error)

func (*UnimplementedSkaffoldServiceServer) GetState 

func (*UnimplementedSkaffoldServiceServer) GetState(ctx context.Context, req *empty.Empty) (*State, error)

func (*UnimplementedSkaffoldServiceServer) Handle 

func (*UnimplementedSkaffoldServiceServer) Handle(ctx context.Context, req *Event) (*empty.Empty, error)

type UserIntentRequest added in v0.34.1 

type UserIntentRequest struct {
	Intent               *Intent  `protobuf:"bytes,1,opt,name=intent,proto3" json:"intent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserIntentRequest) Descriptor added in v0.34.1 

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

func (*UserIntentRequest) GetIntent added in v0.34.1 

func (m *UserIntentRequest) GetIntent() *Intent

func (*UserIntentRequest) ProtoMessage added in v0.34.1 

func (*UserIntentRequest) ProtoMessage()

func (*UserIntentRequest) Reset added in v0.34.1 

func (m *UserIntentRequest) Reset()

func (*UserIntentRequest) String added in v0.34.1 

func (m *UserIntentRequest) String() string

func (*UserIntentRequest) XXX_DiscardUnknown added in v0.34.1 

func (m *UserIntentRequest) XXX_DiscardUnknown()

func (*UserIntentRequest) XXX_Marshal added in v0.34.1 

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

func (*UserIntentRequest) XXX_Merge added in v0.34.1 

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

func (*UserIntentRequest) XXX_Size added in v0.34.1 

func (m *UserIntentRequest) XXX_Size() int

func (*UserIntentRequest) XXX_Unmarshal added in v0.34.1 

func (m *UserIntentRequest) 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.