rpc

package
v1.13.7-rc.8 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package rpc contains files generated by protoc

Index

Constants

This section is empty.

Variables

View Source 
var (
	InterceptError_name = map[int32]string{
		0:  "InterceptOk",
		1:  "NoPreviewHost",
		2:  "NoConnection",
		3:  "NoTrafficManager",
		4:  "TrafficManagerConnecting",
		5:  "TrafficManagerError",
		6:  "AlreadyExists",
		7:  "NoAcceptableDeployment",
		8:  "AmbiguousMatch",
		9:  "FailedToEstablish",
		10: "FailedToRemove",
		11: "NotFound",
	}
	InterceptError_value = map[string]int32{
		"InterceptOk":              0,
		"NoPreviewHost":            1,
		"NoConnection":             2,
		"NoTrafficManager":         3,
		"TrafficManagerConnecting": 4,
		"TrafficManagerError":      5,
		"AlreadyExists":            6,
		"NoAcceptableDeployment":   7,
		"AmbiguousMatch":           8,
		"FailedToEstablish":        9,
		"FailedToRemove":           10,
		"NotFound":                 11,
	}
)

Enum value maps for InterceptError.

View Source 
var (
	ConnectResponse_ErrType_name = map[int32]string{
		0: "Ok",
		1: "AlreadyConnected",
		2: "Disconnecting",
		3: "Paused",
		4: "EstablishingOverrides",
		5: "ClusterFailed",
		6: "BridgeFailed",
		7: "TrafficManagerFailed",
	}
	ConnectResponse_ErrType_value = map[string]int32{
		"Ok":                    0,
		"AlreadyConnected":      1,
		"Disconnecting":         2,
		"Paused":                3,
		"EstablishingOverrides": 4,
		"ClusterFailed":         5,
		"BridgeFailed":          6,
		"TrafficManagerFailed":  7,
	}
)

Enum value maps for ConnectResponse_ErrType.

View Source 
var (
	DisconnectResponse_ErrType_name = map[int32]string{
		0: "Ok",
		1: "NotConnected",
		2: "DisconnectFailed",
	}
	DisconnectResponse_ErrType_value = map[string]int32{
		"Ok":               0,
		"NotConnected":     1,
		"DisconnectFailed": 2,
	}
)

Enum value maps for DisconnectResponse_ErrType.

View Source 
var (
	PauseResponse_ErrType_name = map[int32]string{
		0: "Ok",
		1: "AlreadyPaused",
		2: "ConnectedToCluster",
		3: "UnexpectedPauseError",
	}
	PauseResponse_ErrType_value = map[string]int32{
		"Ok":                   0,
		"AlreadyPaused":        1,
		"ConnectedToCluster":   2,
		"UnexpectedPauseError": 3,
	}
)

Enum value maps for PauseResponse_ErrType.

View Source 
var (
	ResumeResponse_ErrType_name = map[int32]string{
		0: "Ok",
		1: "NotPaused",
		2: "ReEstablishing",
		3: "UnexpectedResumeError",
	}
	ResumeResponse_ErrType_value = map[string]int32{
		"Ok":                    0,
		"NotPaused":             1,
		"ReEstablishing":        2,
		"UnexpectedResumeError": 3,
	}
)

Enum value maps for ResumeResponse_ErrType.

View Source 
var (
	StatusResponse_ErrType_name = map[int32]string{
		0: "Ok",
		1: "Paused",
		2: "NoNetwork",
		3: "Disconnected",
	}
	StatusResponse_ErrType_value = map[string]int32{
		"Ok":           0,
		"Paused":       1,
		"NoNetwork":    2,
		"Disconnected": 3,
	}
)

Enum value maps for StatusResponse_ErrType.

View Source 
var File_edgectl_rpc_daemon_proto protoreflect.FileDescriptor

Functions

func RegisterDaemonServer 

func RegisterDaemonServer(s *grpc.Server, srv DaemonServer)

Types

type AvailableInterceptsResponse 

type AvailableInterceptsResponse struct {
	Error      InterceptError                           `protobuf:"varint,1,opt,name=Error,proto3,enum=edgectl.InterceptError" json:"Error,omitempty"`
	Text       string                                   `protobuf:"bytes,2,opt,name=Text,proto3" json:"Text,omitempty"`
	Intercepts []*AvailableInterceptsResponse_ListEntry `protobuf:"bytes,3,rep,name=Intercepts,proto3" json:"Intercepts,omitempty"`
	// contains filtered or unexported fields
}

func (*AvailableInterceptsResponse) Descriptor deprecated 

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

Deprecated: Use AvailableInterceptsResponse.ProtoReflect.Descriptor instead.

func (*AvailableInterceptsResponse) GetError 

func (x *AvailableInterceptsResponse) GetError() InterceptError

func (*AvailableInterceptsResponse) GetIntercepts 

func (x *AvailableInterceptsResponse) GetIntercepts() []*AvailableInterceptsResponse_ListEntry

func (*AvailableInterceptsResponse) GetText 

func (x *AvailableInterceptsResponse) GetText() string

func (*AvailableInterceptsResponse) ProtoMessage 

func (*AvailableInterceptsResponse) ProtoMessage()

func (*AvailableInterceptsResponse) ProtoReflect 

func (x *AvailableInterceptsResponse) ProtoReflect() protoreflect.Message

func (*AvailableInterceptsResponse) Reset 

func (x *AvailableInterceptsResponse) Reset()

func (*AvailableInterceptsResponse) String 

func (x *AvailableInterceptsResponse) String() string

type AvailableInterceptsResponse_ListEntry 

type AvailableInterceptsResponse_ListEntry struct {
	Namespace  string `protobuf:"bytes,1,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	Deployment string `protobuf:"bytes,2,opt,name=Deployment,proto3" json:"Deployment,omitempty"`
	// contains filtered or unexported fields
}

func (*AvailableInterceptsResponse_ListEntry) Descriptor deprecated 

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

Deprecated: Use AvailableInterceptsResponse_ListEntry.ProtoReflect.Descriptor instead.

func (*AvailableInterceptsResponse_ListEntry) GetDeployment 

func (x *AvailableInterceptsResponse_ListEntry) GetDeployment() string

func (*AvailableInterceptsResponse_ListEntry) GetNamespace 

func (x *AvailableInterceptsResponse_ListEntry) GetNamespace() string

func (*AvailableInterceptsResponse_ListEntry) ProtoMessage 

func (*AvailableInterceptsResponse_ListEntry) ProtoMessage()

func (*AvailableInterceptsResponse_ListEntry) ProtoReflect 

func (x *AvailableInterceptsResponse_ListEntry) ProtoReflect() protoreflect.Message

func (*AvailableInterceptsResponse_ListEntry) Reset 

func (x *AvailableInterceptsResponse_ListEntry) Reset()

func (*AvailableInterceptsResponse_ListEntry) String 

func (x *AvailableInterceptsResponse_ListEntry) String() string

type ConnectRequest 

type ConnectRequest struct {
	Context        string                   `protobuf:"bytes,1,opt,name=Context,proto3" json:"Context,omitempty"`
	Namespace      string                   `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	ManagerNS      string                   `protobuf:"bytes,3,opt,name=ManagerNS,proto3" json:"ManagerNS,omitempty"`
	InstallID      string                   `protobuf:"bytes,4,opt,name=InstallID,proto3" json:"InstallID,omitempty"`
	IsCI           bool                     `protobuf:"varint,5,opt,name=IsCI,proto3" json:"IsCI,omitempty"`
	WaitForNetwork int32                    `protobuf:"varint,6,opt,name=WaitForNetwork,proto3" json:"WaitForNetwork,omitempty"`
	Args           []string                 `protobuf:"bytes,7,rep,name=Args,proto3" json:"Args,omitempty"`
	User           *ConnectRequest_UserInfo `protobuf:"bytes,8,opt,name=User,proto3" json:"User,omitempty"` // Remove when connector runs as user
	// contains filtered or unexported fields
}

ConnectRequest contains the information needed to connect ot a cluster.

func (*ConnectRequest) Descriptor deprecated 

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

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetArgs 

func (x *ConnectRequest) GetArgs() []string

func (*ConnectRequest) GetContext 

func (x *ConnectRequest) GetContext() string

func (*ConnectRequest) GetInstallID 

func (x *ConnectRequest) GetInstallID() string

func (*ConnectRequest) GetIsCI 

func (x *ConnectRequest) GetIsCI() bool

func (*ConnectRequest) GetManagerNS 

func (x *ConnectRequest) GetManagerNS() string

func (*ConnectRequest) GetNamespace 

func (x *ConnectRequest) GetNamespace() string

func (*ConnectRequest) GetUser 

func (x *ConnectRequest) GetUser() *ConnectRequest_UserInfo

func (*ConnectRequest) GetWaitForNetwork 

func (x *ConnectRequest) GetWaitForNetwork() int32

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect 

func (x *ConnectRequest) ProtoReflect() protoreflect.Message

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

type ConnectRequest_UserInfo 

type ConnectRequest_UserInfo struct {
	Name string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Cwd  string   `protobuf:"bytes,2,opt,name=Cwd,proto3" json:"Cwd,omitempty"`
	Env  []string `protobuf:"bytes,3,rep,name=Env,proto3" json:"Env,omitempty"`
	// contains filtered or unexported fields
}

UserInfo contains information needed when the daemon shells out as another user. This is subject to change in the near future and this message type will be removed.

func (*ConnectRequest_UserInfo) Descriptor deprecated 

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

Deprecated: Use ConnectRequest_UserInfo.ProtoReflect.Descriptor instead.

func (*ConnectRequest_UserInfo) GetCwd 

func (x *ConnectRequest_UserInfo) GetCwd() string

func (*ConnectRequest_UserInfo) GetEnv 

func (x *ConnectRequest_UserInfo) GetEnv() []string

func (*ConnectRequest_UserInfo) GetName 

func (x *ConnectRequest_UserInfo) GetName() string

func (*ConnectRequest_UserInfo) ProtoMessage 

func (*ConnectRequest_UserInfo) ProtoMessage()

func (*ConnectRequest_UserInfo) ProtoReflect 

func (x *ConnectRequest_UserInfo) ProtoReflect() protoreflect.Message

func (*ConnectRequest_UserInfo) Reset 

func (x *ConnectRequest_UserInfo) Reset()

func (*ConnectRequest_UserInfo) String 

func (x *ConnectRequest_UserInfo) String() string

type ConnectResponse 

type ConnectResponse struct {
	Error          ConnectResponse_ErrType `protobuf:"varint,1,opt,name=Error,proto3,enum=edgectl.ConnectResponse_ErrType" json:"Error,omitempty"`
	ErrorText      string                  `protobuf:"bytes,2,opt,name=ErrorText,proto3" json:"ErrorText,omitempty"`
	ClusterContext string                  `protobuf:"bytes,3,opt,name=ClusterContext,proto3" json:"ClusterContext,omitempty"`
	ClusterServer  string                  `protobuf:"bytes,4,opt,name=ClusterServer,proto3" json:"ClusterServer,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectResponse) Descriptor deprecated 

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

Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse) GetClusterContext 

func (x *ConnectResponse) GetClusterContext() string

func (*ConnectResponse) GetClusterServer 

func (x *ConnectResponse) GetClusterServer() string

func (*ConnectResponse) GetError 

func (x *ConnectResponse) GetError() ConnectResponse_ErrType

func (*ConnectResponse) GetErrorText 

func (x *ConnectResponse) GetErrorText() string

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) ProtoReflect 

func (x *ConnectResponse) ProtoReflect() protoreflect.Message

func (*ConnectResponse) Reset 

func (x *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (x *ConnectResponse) String() string

type ConnectResponse_ErrType 

type ConnectResponse_ErrType int32
const (
	ConnectResponse_Ok                    ConnectResponse_ErrType = 0
	ConnectResponse_AlreadyConnected      ConnectResponse_ErrType = 1
	ConnectResponse_Disconnecting         ConnectResponse_ErrType = 2
	ConnectResponse_Paused                ConnectResponse_ErrType = 3
	ConnectResponse_EstablishingOverrides ConnectResponse_ErrType = 4
	ConnectResponse_ClusterFailed         ConnectResponse_ErrType = 5
	ConnectResponse_BridgeFailed          ConnectResponse_ErrType = 6
	ConnectResponse_TrafficManagerFailed  ConnectResponse_ErrType = 7
)

func (ConnectResponse_ErrType) Descriptor 

func (ConnectResponse_ErrType) Descriptor() protoreflect.EnumDescriptor

func (ConnectResponse_ErrType) Enum 

func (x ConnectResponse_ErrType) Enum() *ConnectResponse_ErrType

func (ConnectResponse_ErrType) EnumDescriptor deprecated 

func (ConnectResponse_ErrType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConnectResponse_ErrType.Descriptor instead.

func (ConnectResponse_ErrType) Number 

func (x ConnectResponse_ErrType) Number() protoreflect.EnumNumber

func (ConnectResponse_ErrType) String 

func (x ConnectResponse_ErrType) String() string

func (ConnectResponse_ErrType) Type 

func (ConnectResponse_ErrType) Type() protoreflect.EnumType

type DaemonClient 

type DaemonClient interface {
	// Returns version information from the Daemon
	Version(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionResponse, error)
	// Returns the current connectivity status
	Status(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StatusResponse, error)
	// Connects the daemon to a cluster
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)
	// Disconnects the daemon from a connected cluster
	Disconnect(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DisconnectResponse, error)
	// Adds a deployment intercept
	AddIntercept(ctx context.Context, in *InterceptRequest, opts ...grpc.CallOption) (*InterceptResponse, error)
	// Deactivates and removes an existent deployment intercept.
	RemoveIntercept(ctx context.Context, in *RemoveInterceptRequest, opts ...grpc.CallOption) (*InterceptResponse, error)
	// Returns a list of deployments available for intercept.
	AvailableIntercepts(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*AvailableInterceptsResponse, error)
	// Returns a list of currently active intercepts.
	ListIntercepts(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListInterceptsResponse, error)
	// Turns network overrides off.
	Pause(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PauseResponse, error)
	// Turns network overrides back on (after using Pause)
	Resume(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ResumeResponse, error)
	// Quits (terminates) the service.
	Quit(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}

DaemonClient is the client API for Daemon service.

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

func NewDaemonClient 

func NewDaemonClient(cc grpc.ClientConnInterface) DaemonClient

type DaemonServer 

type DaemonServer interface {
	// Returns version information from the Daemon
	Version(context.Context, *Empty) (*VersionResponse, error)
	// Returns the current connectivity status
	Status(context.Context, *Empty) (*StatusResponse, error)
	// Connects the daemon to a cluster
	Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
	// Disconnects the daemon from a connected cluster
	Disconnect(context.Context, *Empty) (*DisconnectResponse, error)
	// Adds a deployment intercept
	AddIntercept(context.Context, *InterceptRequest) (*InterceptResponse, error)
	// Deactivates and removes an existent deployment intercept.
	RemoveIntercept(context.Context, *RemoveInterceptRequest) (*InterceptResponse, error)
	// Returns a list of deployments available for intercept.
	AvailableIntercepts(context.Context, *Empty) (*AvailableInterceptsResponse, error)
	// Returns a list of currently active intercepts.
	ListIntercepts(context.Context, *Empty) (*ListInterceptsResponse, error)
	// Turns network overrides off.
	Pause(context.Context, *Empty) (*PauseResponse, error)
	// Turns network overrides back on (after using Pause)
	Resume(context.Context, *Empty) (*ResumeResponse, error)
	// Quits (terminates) the service.
	Quit(context.Context, *Empty) (*Empty, error)
}

DaemonServer is the server API for Daemon service.

type DisconnectResponse 

type DisconnectResponse struct {
	Error     DisconnectResponse_ErrType `protobuf:"varint,1,opt,name=Error,proto3,enum=edgectl.DisconnectResponse_ErrType" json:"Error,omitempty"`
	ErrorText string                     `protobuf:"bytes,2,opt,name=ErrorText,proto3" json:"ErrorText,omitempty"`
	// contains filtered or unexported fields
}

func (*DisconnectResponse) Descriptor deprecated 

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

Deprecated: Use DisconnectResponse.ProtoReflect.Descriptor instead.

func (*DisconnectResponse) GetError 

func (x *DisconnectResponse) GetError() DisconnectResponse_ErrType

func (*DisconnectResponse) GetErrorText 

func (x *DisconnectResponse) GetErrorText() string

func (*DisconnectResponse) ProtoMessage 

func (*DisconnectResponse) ProtoMessage()

func (*DisconnectResponse) ProtoReflect 

func (x *DisconnectResponse) ProtoReflect() protoreflect.Message

func (*DisconnectResponse) Reset 

func (x *DisconnectResponse) Reset()

func (*DisconnectResponse) String 

func (x *DisconnectResponse) String() string

type DisconnectResponse_ErrType 

type DisconnectResponse_ErrType int32
const (
	DisconnectResponse_Ok               DisconnectResponse_ErrType = 0
	DisconnectResponse_NotConnected     DisconnectResponse_ErrType = 1
	DisconnectResponse_DisconnectFailed DisconnectResponse_ErrType = 2
)

func (DisconnectResponse_ErrType) Descriptor 

func (DisconnectResponse_ErrType) Descriptor() protoreflect.EnumDescriptor

func (DisconnectResponse_ErrType) Enum 

func (x DisconnectResponse_ErrType) Enum() *DisconnectResponse_ErrType

func (DisconnectResponse_ErrType) EnumDescriptor deprecated 

func (DisconnectResponse_ErrType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DisconnectResponse_ErrType.Descriptor instead.

func (DisconnectResponse_ErrType) Number 

func (x DisconnectResponse_ErrType) Number() protoreflect.EnumNumber

func (DisconnectResponse_ErrType) String 

func (x DisconnectResponse_ErrType) String() string

func (DisconnectResponse_ErrType) Type 

func (DisconnectResponse_ErrType) Type() protoreflect.EnumType

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type InterceptError 

type InterceptError int32

InterceptError is a common error type used by the intercept call family (add, remove, list, available). 

const (
	InterceptError_InterceptOk              InterceptError = 0
	InterceptError_NoPreviewHost            InterceptError = 1
	InterceptError_NoConnection             InterceptError = 2
	InterceptError_NoTrafficManager         InterceptError = 3
	InterceptError_TrafficManagerConnecting InterceptError = 4
	InterceptError_TrafficManagerError      InterceptError = 5
	InterceptError_AlreadyExists            InterceptError = 6
	InterceptError_NoAcceptableDeployment   InterceptError = 7
	InterceptError_AmbiguousMatch           InterceptError = 8
	InterceptError_FailedToEstablish        InterceptError = 9
	InterceptError_FailedToRemove           InterceptError = 10
	InterceptError_NotFound                 InterceptError = 11
)

func (InterceptError) Descriptor 

func (InterceptError) Descriptor() protoreflect.EnumDescriptor

func (InterceptError) Enum 

func (x InterceptError) Enum() *InterceptError

func (InterceptError) EnumDescriptor deprecated 

func (InterceptError) EnumDescriptor() ([]byte, []int)

Deprecated: Use InterceptError.Descriptor instead.

func (InterceptError) Number 

func (x InterceptError) Number() protoreflect.EnumNumber

func (InterceptError) String 

func (x InterceptError) String() string

func (InterceptError) Type 

func (InterceptError) Type() protoreflect.EnumType

type InterceptRequest 

type InterceptRequest struct {

	// Name of the intercept
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// Namespace in which to create the Intercept mapping
	Namespace string `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	// Name of the deployment being intercepted
	Deployment string `protobuf:"bytes,3,opt,name=Deployment,proto3" json:"Deployment,omitempty"`
	// Prefix to intercept (default /)
	Prefix     string `protobuf:"bytes,4,opt,name=Prefix,proto3" json:"Prefix,omitempty"`
	TargetHost string `protobuf:"bytes,5,opt,name=TargetHost,proto3" json:"TargetHost,omitempty"`
	TargetPort int32  `protobuf:"varint,6,opt,name=TargetPort,proto3" json:"TargetPort,omitempty"`
	// GRPC flag to set on the Intercept mapping. Ideally we'd get this from the
	// Traffic-Manager interceptables instead of having to pass it as a CLI argument.
	GRPC     bool              `protobuf:"varint,7,opt,name=GRPC,proto3" json:"GRPC,omitempty"`
	Preview  bool              `protobuf:"varint,8,opt,name=Preview,proto3" json:"Preview,omitempty"`
	Patterns map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

InterceptRequest contains the information needed to add a deployment intercept.

func (*InterceptRequest) Descriptor deprecated 

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

Deprecated: Use InterceptRequest.ProtoReflect.Descriptor instead.

func (*InterceptRequest) GetDeployment 

func (x *InterceptRequest) GetDeployment() string

func (*InterceptRequest) GetGRPC 

func (x *InterceptRequest) GetGRPC() bool

func (*InterceptRequest) GetName 

func (x *InterceptRequest) GetName() string

func (*InterceptRequest) GetNamespace 

func (x *InterceptRequest) GetNamespace() string

func (*InterceptRequest) GetPatterns 

func (x *InterceptRequest) GetPatterns() map[string]string

func (*InterceptRequest) GetPrefix 

func (x *InterceptRequest) GetPrefix() string

func (*InterceptRequest) GetPreview 

func (x *InterceptRequest) GetPreview() bool

func (*InterceptRequest) GetTargetHost 

func (x *InterceptRequest) GetTargetHost() string

func (*InterceptRequest) GetTargetPort 

func (x *InterceptRequest) GetTargetPort() int32

func (*InterceptRequest) ProtoMessage 

func (*InterceptRequest) ProtoMessage()

func (*InterceptRequest) ProtoReflect 

func (x *InterceptRequest) ProtoReflect() protoreflect.Message

func (*InterceptRequest) Reset 

func (x *InterceptRequest) Reset()

func (*InterceptRequest) String 

func (x *InterceptRequest) String() string

type InterceptResponse 

type InterceptResponse struct {
	Error      InterceptError `protobuf:"varint,1,opt,name=Error,proto3,enum=edgectl.InterceptError" json:"Error,omitempty"`
	PreviewURL string         `protobuf:"bytes,2,opt,name=PreviewURL,proto3" json:"PreviewURL,omitempty"`
	Text       string         `protobuf:"bytes,3,opt,name=Text,proto3" json:"Text,omitempty"`
	// contains filtered or unexported fields
}

func (*InterceptResponse) Descriptor deprecated 

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

Deprecated: Use InterceptResponse.ProtoReflect.Descriptor instead.

func (*InterceptResponse) GetError 

func (x *InterceptResponse) GetError() InterceptError

func (*InterceptResponse) GetPreviewURL 

func (x *InterceptResponse) GetPreviewURL() string

func (*InterceptResponse) GetText 

func (x *InterceptResponse) GetText() string

func (*InterceptResponse) ProtoMessage 

func (*InterceptResponse) ProtoMessage()

func (*InterceptResponse) ProtoReflect 

func (x *InterceptResponse) ProtoReflect() protoreflect.Message

func (*InterceptResponse) Reset 

func (x *InterceptResponse) Reset()

func (*InterceptResponse) String 

func (x *InterceptResponse) String() string

type ListInterceptsResponse 

type ListInterceptsResponse struct {
	Error      InterceptError                      `protobuf:"varint,1,opt,name=Error,proto3,enum=edgectl.InterceptError" json:"Error,omitempty"`
	Text       string                              `protobuf:"bytes,2,opt,name=Text,proto3" json:"Text,omitempty"`
	Intercepts []*ListInterceptsResponse_ListEntry `protobuf:"bytes,3,rep,name=Intercepts,proto3" json:"Intercepts,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInterceptsResponse) Descriptor deprecated 

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

Deprecated: Use ListInterceptsResponse.ProtoReflect.Descriptor instead.

func (*ListInterceptsResponse) GetError 

func (x *ListInterceptsResponse) GetError() InterceptError

func (*ListInterceptsResponse) GetIntercepts 

func (x *ListInterceptsResponse) GetIntercepts() []*ListInterceptsResponse_ListEntry

func (*ListInterceptsResponse) GetText 

func (x *ListInterceptsResponse) GetText() string

func (*ListInterceptsResponse) ProtoMessage 

func (*ListInterceptsResponse) ProtoMessage()

func (*ListInterceptsResponse) ProtoReflect 

func (x *ListInterceptsResponse) ProtoReflect() protoreflect.Message

func (*ListInterceptsResponse) Reset 

func (x *ListInterceptsResponse) Reset()

func (*ListInterceptsResponse) String 

func (x *ListInterceptsResponse) String() string

type ListInterceptsResponse_ListEntry 

type ListInterceptsResponse_ListEntry struct {
	Name       string            `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Namespace  string            `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	Deployment string            `protobuf:"bytes,3,opt,name=Deployment,proto3" json:"Deployment,omitempty"`
	PreviewURL string            `protobuf:"bytes,4,opt,name=PreviewURL,proto3" json:"PreviewURL,omitempty"`
	Patterns   map[string]string `` /* 157-byte string literal not displayed */
	TargetHost string            `protobuf:"bytes,6,opt,name=TargetHost,proto3" json:"TargetHost,omitempty"`
	TargetPort int32             `protobuf:"varint,7,opt,name=TargetPort,proto3" json:"TargetPort,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInterceptsResponse_ListEntry) Descriptor deprecated 

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

Deprecated: Use ListInterceptsResponse_ListEntry.ProtoReflect.Descriptor instead.

func (*ListInterceptsResponse_ListEntry) GetDeployment 

func (x *ListInterceptsResponse_ListEntry) GetDeployment() string

func (*ListInterceptsResponse_ListEntry) GetName 

func (x *ListInterceptsResponse_ListEntry) GetName() string

func (*ListInterceptsResponse_ListEntry) GetNamespace 

func (x *ListInterceptsResponse_ListEntry) GetNamespace() string

func (*ListInterceptsResponse_ListEntry) GetPatterns 

func (x *ListInterceptsResponse_ListEntry) GetPatterns() map[string]string

func (*ListInterceptsResponse_ListEntry) GetPreviewURL 

func (x *ListInterceptsResponse_ListEntry) GetPreviewURL() string

func (*ListInterceptsResponse_ListEntry) GetTargetHost 

func (x *ListInterceptsResponse_ListEntry) GetTargetHost() string

func (*ListInterceptsResponse_ListEntry) GetTargetPort 

func (x *ListInterceptsResponse_ListEntry) GetTargetPort() int32

func (*ListInterceptsResponse_ListEntry) ProtoMessage 

func (*ListInterceptsResponse_ListEntry) ProtoMessage()

func (*ListInterceptsResponse_ListEntry) ProtoReflect 

func (x *ListInterceptsResponse_ListEntry) ProtoReflect() protoreflect.Message

func (*ListInterceptsResponse_ListEntry) Reset 

func (x *ListInterceptsResponse_ListEntry) Reset()

func (*ListInterceptsResponse_ListEntry) String 

func (x *ListInterceptsResponse_ListEntry) String() string

type PauseResponse 

type PauseResponse struct {
	Error     PauseResponse_ErrType `protobuf:"varint,1,opt,name=Error,proto3,enum=edgectl.PauseResponse_ErrType" json:"Error,omitempty"`
	ErrorText string                `protobuf:"bytes,2,opt,name=ErrorText,proto3" json:"ErrorText,omitempty"`
	// contains filtered or unexported fields
}

func (*PauseResponse) Descriptor deprecated 

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

Deprecated: Use PauseResponse.ProtoReflect.Descriptor instead.

func (*PauseResponse) GetError 

func (x *PauseResponse) GetError() PauseResponse_ErrType

func (*PauseResponse) GetErrorText 

func (x *PauseResponse) GetErrorText() string

func (*PauseResponse) ProtoMessage 

func (*PauseResponse) ProtoMessage()

func (*PauseResponse) ProtoReflect 

func (x *PauseResponse) ProtoReflect() protoreflect.Message

func (*PauseResponse) Reset 

func (x *PauseResponse) Reset()

func (*PauseResponse) String 

func (x *PauseResponse) String() string

type PauseResponse_ErrType 

type PauseResponse_ErrType int32
const (
	PauseResponse_Ok                   PauseResponse_ErrType = 0
	PauseResponse_AlreadyPaused        PauseResponse_ErrType = 1
	PauseResponse_ConnectedToCluster   PauseResponse_ErrType = 2
	PauseResponse_UnexpectedPauseError PauseResponse_ErrType = 3
)

func (PauseResponse_ErrType) Descriptor 

func (PauseResponse_ErrType) Descriptor() protoreflect.EnumDescriptor

func (PauseResponse_ErrType) Enum 

func (x PauseResponse_ErrType) Enum() *PauseResponse_ErrType

func (PauseResponse_ErrType) EnumDescriptor deprecated 

func (PauseResponse_ErrType) EnumDescriptor() ([]byte, []int)

Deprecated: Use PauseResponse_ErrType.Descriptor instead.

func (PauseResponse_ErrType) Number 

func (x PauseResponse_ErrType) Number() protoreflect.EnumNumber

func (PauseResponse_ErrType) String 

func (x PauseResponse_ErrType) String() string

func (PauseResponse_ErrType) Type 

func (PauseResponse_ErrType) Type() protoreflect.EnumType

type RemoveInterceptRequest 

type RemoveInterceptRequest struct {

	// Name of the intercept
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveInterceptRequest) Descriptor deprecated 

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

Deprecated: Use RemoveInterceptRequest.ProtoReflect.Descriptor instead.

func (*RemoveInterceptRequest) GetName 

func (x *RemoveInterceptRequest) GetName() string

func (*RemoveInterceptRequest) ProtoMessage 

func (*RemoveInterceptRequest) ProtoMessage()

func (*RemoveInterceptRequest) ProtoReflect 

func (x *RemoveInterceptRequest) ProtoReflect() protoreflect.Message

func (*RemoveInterceptRequest) Reset 

func (x *RemoveInterceptRequest) Reset()

func (*RemoveInterceptRequest) String 

func (x *RemoveInterceptRequest) String() string

type ResumeResponse 

type ResumeResponse struct {
	Error     ResumeResponse_ErrType `protobuf:"varint,1,opt,name=Error,proto3,enum=edgectl.ResumeResponse_ErrType" json:"Error,omitempty"`
	ErrorText string                 `protobuf:"bytes,2,opt,name=ErrorText,proto3" json:"ErrorText,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeResponse) Descriptor deprecated 

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

Deprecated: Use ResumeResponse.ProtoReflect.Descriptor instead.

func (*ResumeResponse) GetError 

func (x *ResumeResponse) GetError() ResumeResponse_ErrType

func (*ResumeResponse) GetErrorText 

func (x *ResumeResponse) GetErrorText() string

func (*ResumeResponse) ProtoMessage 

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) ProtoReflect 

func (x *ResumeResponse) ProtoReflect() protoreflect.Message

func (*ResumeResponse) Reset 

func (x *ResumeResponse) Reset()

func (*ResumeResponse) String 

func (x *ResumeResponse) String() string

type ResumeResponse_ErrType 

type ResumeResponse_ErrType int32
const (
	ResumeResponse_Ok                    ResumeResponse_ErrType = 0
	ResumeResponse_NotPaused             ResumeResponse_ErrType = 1
	ResumeResponse_ReEstablishing        ResumeResponse_ErrType = 2
	ResumeResponse_UnexpectedResumeError ResumeResponse_ErrType = 3
)

func (ResumeResponse_ErrType) Descriptor 

func (ResumeResponse_ErrType) Descriptor() protoreflect.EnumDescriptor

func (ResumeResponse_ErrType) Enum 

func (x ResumeResponse_ErrType) Enum() *ResumeResponse_ErrType

func (ResumeResponse_ErrType) EnumDescriptor deprecated 

func (ResumeResponse_ErrType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ResumeResponse_ErrType.Descriptor instead.

func (ResumeResponse_ErrType) Number 

func (x ResumeResponse_ErrType) Number() protoreflect.EnumNumber

func (ResumeResponse_ErrType) String 

func (x ResumeResponse_ErrType) String() string

func (ResumeResponse_ErrType) Type 

func (ResumeResponse_ErrType) Type() protoreflect.EnumType

type StatusResponse 

type StatusResponse struct {
	Error      StatusResponse_ErrType         `protobuf:"varint,1,opt,name=Error,proto3,enum=edgectl.StatusResponse_ErrType" json:"Error,omitempty"`
	ErrorText  string                         `protobuf:"bytes,2,opt,name=ErrorText,proto3" json:"ErrorText,omitempty"`
	Bridge     bool                           `protobuf:"varint,3,opt,name=Bridge,proto3" json:"Bridge,omitempty"`
	Cluster    *StatusResponse_ClusterInfo    `protobuf:"bytes,4,opt,name=Cluster,proto3" json:"Cluster,omitempty"`
	Intercepts *StatusResponse_InterceptsInfo `protobuf:"bytes,5,opt,name=Intercepts,proto3" json:"Intercepts,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetBridge 

func (x *StatusResponse) GetBridge() bool

func (*StatusResponse) GetCluster 

func (x *StatusResponse) GetCluster() *StatusResponse_ClusterInfo

func (*StatusResponse) GetError 

func (x *StatusResponse) GetError() StatusResponse_ErrType

func (*StatusResponse) GetErrorText 

func (x *StatusResponse) GetErrorText() string

func (*StatusResponse) GetIntercepts 

func (x *StatusResponse) GetIntercepts() *StatusResponse_InterceptsInfo

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

func (x *StatusResponse) ProtoReflect() protoreflect.Message

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StatusResponse_ClusterInfo 

type StatusResponse_ClusterInfo struct {
	Connected bool   `protobuf:"varint,1,opt,name=Connected,proto3" json:"Connected,omitempty"`
	Server    string `protobuf:"bytes,2,opt,name=Server,proto3" json:"Server,omitempty"`
	Context   string `protobuf:"bytes,3,opt,name=Context,proto3" json:"Context,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse_ClusterInfo) Descriptor deprecated 

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

Deprecated: Use StatusResponse_ClusterInfo.ProtoReflect.Descriptor instead.

func (*StatusResponse_ClusterInfo) GetConnected 

func (x *StatusResponse_ClusterInfo) GetConnected() bool

func (*StatusResponse_ClusterInfo) GetContext 

func (x *StatusResponse_ClusterInfo) GetContext() string

func (*StatusResponse_ClusterInfo) GetServer 

func (x *StatusResponse_ClusterInfo) GetServer() string

func (*StatusResponse_ClusterInfo) ProtoMessage 

func (*StatusResponse_ClusterInfo) ProtoMessage()

func (*StatusResponse_ClusterInfo) ProtoReflect 

func (x *StatusResponse_ClusterInfo) ProtoReflect() protoreflect.Message

func (*StatusResponse_ClusterInfo) Reset 

func (x *StatusResponse_ClusterInfo) Reset()

func (*StatusResponse_ClusterInfo) String 

func (x *StatusResponse_ClusterInfo) String() string

type StatusResponse_ErrType 

type StatusResponse_ErrType int32
const (
	StatusResponse_Ok           StatusResponse_ErrType = 0
	StatusResponse_Paused       StatusResponse_ErrType = 1
	StatusResponse_NoNetwork    StatusResponse_ErrType = 2
	StatusResponse_Disconnected StatusResponse_ErrType = 3
)

func (StatusResponse_ErrType) Descriptor 

func (StatusResponse_ErrType) Descriptor() protoreflect.EnumDescriptor

func (StatusResponse_ErrType) Enum 

func (x StatusResponse_ErrType) Enum() *StatusResponse_ErrType

func (StatusResponse_ErrType) EnumDescriptor deprecated 

func (StatusResponse_ErrType) EnumDescriptor() ([]byte, []int)

Deprecated: Use StatusResponse_ErrType.Descriptor instead.

func (StatusResponse_ErrType) Number 

func (x StatusResponse_ErrType) Number() protoreflect.EnumNumber

func (StatusResponse_ErrType) String 

func (x StatusResponse_ErrType) String() string

func (StatusResponse_ErrType) Type 

func (StatusResponse_ErrType) Type() protoreflect.EnumType

type StatusResponse_InterceptsInfo 

type StatusResponse_InterceptsInfo struct {
	Connected          bool   `protobuf:"varint,1,opt,name=Connected,proto3" json:"Connected,omitempty"`
	InterceptableCount int32  `protobuf:"varint,2,opt,name=InterceptableCount,proto3" json:"InterceptableCount,omitempty"`
	ClusterIntercepts  int32  `protobuf:"varint,3,opt,name=ClusterIntercepts,proto3" json:"ClusterIntercepts,omitempty"`
	LocalIntercepts    int32  `protobuf:"varint,4,opt,name=LocalIntercepts,proto3" json:"LocalIntercepts,omitempty"`
	LicenseInfo        string `protobuf:"bytes,5,opt,name=LicenseInfo,proto3" json:"LicenseInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse_InterceptsInfo) Descriptor deprecated 

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

Deprecated: Use StatusResponse_InterceptsInfo.ProtoReflect.Descriptor instead.

func (*StatusResponse_InterceptsInfo) GetClusterIntercepts 

func (x *StatusResponse_InterceptsInfo) GetClusterIntercepts() int32

func (*StatusResponse_InterceptsInfo) GetConnected 

func (x *StatusResponse_InterceptsInfo) GetConnected() bool

func (*StatusResponse_InterceptsInfo) GetInterceptableCount 

func (x *StatusResponse_InterceptsInfo) GetInterceptableCount() int32

func (*StatusResponse_InterceptsInfo) GetLicenseInfo 

func (x *StatusResponse_InterceptsInfo) GetLicenseInfo() string

func (*StatusResponse_InterceptsInfo) GetLocalIntercepts 

func (x *StatusResponse_InterceptsInfo) GetLocalIntercepts() int32

func (*StatusResponse_InterceptsInfo) ProtoMessage 

func (*StatusResponse_InterceptsInfo) ProtoMessage()

func (*StatusResponse_InterceptsInfo) ProtoReflect 

func (x *StatusResponse_InterceptsInfo) ProtoReflect() protoreflect.Message

func (*StatusResponse_InterceptsInfo) Reset 

func (x *StatusResponse_InterceptsInfo) Reset()

func (*StatusResponse_InterceptsInfo) String 

func (x *StatusResponse_InterceptsInfo) String() string

type UnimplementedDaemonServer 

type UnimplementedDaemonServer struct {
}

UnimplementedDaemonServer can be embedded to have forward compatible implementations.

func (*UnimplementedDaemonServer) AddIntercept 

func (*UnimplementedDaemonServer) AddIntercept(context.Context, *InterceptRequest) (*InterceptResponse, error)

func (*UnimplementedDaemonServer) AvailableIntercepts 

func (*UnimplementedDaemonServer) AvailableIntercepts(context.Context, *Empty) (*AvailableInterceptsResponse, error)

func (*UnimplementedDaemonServer) Connect 

func (*UnimplementedDaemonServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)

func (*UnimplementedDaemonServer) Disconnect 

func (*UnimplementedDaemonServer) Disconnect(context.Context, *Empty) (*DisconnectResponse, error)

func (*UnimplementedDaemonServer) ListIntercepts 

func (*UnimplementedDaemonServer) ListIntercepts(context.Context, *Empty) (*ListInterceptsResponse, error)

func (*UnimplementedDaemonServer) Pause 

func (*UnimplementedDaemonServer) Pause(context.Context, *Empty) (*PauseResponse, error)

func (*UnimplementedDaemonServer) Quit 

func (*UnimplementedDaemonServer) Quit(context.Context, *Empty) (*Empty, error)

func (*UnimplementedDaemonServer) RemoveIntercept 

func (*UnimplementedDaemonServer) RemoveIntercept(context.Context, *RemoveInterceptRequest) (*InterceptResponse, error)

func (*UnimplementedDaemonServer) Resume 

func (*UnimplementedDaemonServer) Resume(context.Context, *Empty) (*ResumeResponse, error)

func (*UnimplementedDaemonServer) Status 

func (*UnimplementedDaemonServer) Status(context.Context, *Empty) (*StatusResponse, error)

func (*UnimplementedDaemonServer) Version 

func (*UnimplementedDaemonServer) Version(context.Context, *Empty) (*VersionResponse, error)

type VersionResponse 

type VersionResponse struct {
	APIVersion int32  `protobuf:"varint,1,opt,name=APIVersion,proto3" json:"APIVersion,omitempty"`
	Version    string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetAPIVersion 

func (x *VersionResponse) GetAPIVersion() int32

func (*VersionResponse) GetVersion 

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

func (x *VersionResponse) ProtoReflect() protoreflect.Message

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) String 

func (x *VersionResponse) String() string

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.