eva

package
v0.0.0-...-6e34d32 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var LifecycleCommand_Command_name = map[int32]string{
	0: "START",
	1: "STOP",
	2: "RESTART",
}
View Source 
var LifecycleCommand_Command_value = map[string]int32{
	"START":   0,
	"STOP":    1,
	"RESTART": 2,
}
View Source 
var LifecycleStatus_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "DEPLOYING",
	2: "READY",
	3: "STARTING",
	4: "RUNNING",
	5: "STOPPING",
	6: "STOPPED",
	7: "ERROR",
}
View Source 
var LifecycleStatus_Status_value = map[string]int32{
	"UNKNOWN":   0,
	"DEPLOYING": 1,
	"READY":     2,
	"STARTING":  3,
	"RUNNING":   4,
	"STOPPING":  5,
	"STOPPED":   6,
	"ERROR":     7,
}

Functions

func RegisterApplicationDeploymentServiceServer 

func RegisterApplicationDeploymentServiceServer(s *grpc.Server, srv ApplicationDeploymentServiceServer)

func RegisterApplicationLifecycleServiceServer 

func RegisterApplicationLifecycleServiceServer(s *grpc.Server, srv ApplicationLifecycleServiceServer)

func RegisterControllerVirtualizationAgentServer 

func RegisterControllerVirtualizationAgentServer(s *grpc.Server, srv ControllerVirtualizationAgentServer)

Types

type Application 

type Application struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version     string                 `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Vendor      string                 `protobuf:"bytes,4,opt,name=vendor,proto3" json:"vendor,omitempty"`
	Description string                 `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Cores       int32                  `protobuf:"varint,6,opt,name=cores,proto3" json:"cores,omitempty"`
	Memory      int32                  `protobuf:"varint,7,opt,name=memory,proto3" json:"memory,omitempty"`
	Ports       []*PortProto           `protobuf:"bytes,8,rep,name=ports,proto3" json:"ports,omitempty"`
	Status      LifecycleStatus_Status `protobuf:"varint,9,opt,name=status,proto3,enum=openness.eva.LifecycleStatus_Status" json:"status,omitempty"`
	// Source to retrieve the container or VM from. It is expected that more
	// sources will be added over time.
	//
	// Types that are valid to be assigned to Source:
	//	*Application_HttpUri
	Source isApplication_Source `protobuf_oneof:"source"`
	// This contains a specification of the EAC features that this application wants.
	// (Enhanced App Configuration). This is in Json format - but is at top level
	// an array of string key-value pairs. Specific keys are defined by their respective features.
	EACJsonBlob string `protobuf:"bytes,11,opt,name=EACJsonBlob,proto3" json:"EACJsonBlob,omitempty"`
	// CNI configuration for the application
	CniConf              *CNIConfiguration `protobuf:"bytes,12,opt,name=cniConf,proto3" json:"cniConf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Application message - contains information about the application we're about to deploy (or one already deployed).

Image sources will be added over time. For example, pulling from external Docker registries may be supported with a source such as: 

// Image will be downloaded from a Docker registry
message DockerRegistrySource {
    string repo = 1;
    string tag = 2;

    // authentication
    string user = 3;
    string token = 4;
}

And then adding to the source field: 

oneof source {
    ...
    DockerRegistrySource docker_registry = 9 + N;
}

func (*Application) Descriptor 

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

func (*Application) GetCniConf 

func (m *Application) GetCniConf() *CNIConfiguration

func (*Application) GetCores 

func (m *Application) GetCores() int32

func (*Application) GetDescription 

func (m *Application) GetDescription() string

func (*Application) GetEACJsonBlob 

func (m *Application) GetEACJsonBlob() string

func (*Application) GetHttpUri 

func (m *Application) GetHttpUri() *Application_HTTPSource

func (*Application) GetId 

func (m *Application) GetId() string

func (*Application) GetMemory 

func (m *Application) GetMemory() int32

func (*Application) GetName 

func (m *Application) GetName() string

func (*Application) GetPorts 

func (m *Application) GetPorts() []*PortProto

func (*Application) GetSource 

func (m *Application) GetSource() isApplication_Source

func (*Application) GetStatus 

func (m *Application) GetStatus() LifecycleStatus_Status

func (*Application) GetVendor 

func (m *Application) GetVendor() string

func (*Application) GetVersion 

func (m *Application) GetVersion() string

func (*Application) ProtoMessage 

func (*Application) ProtoMessage()

func (*Application) Reset 

func (m *Application) Reset()

func (*Application) String 

func (m *Application) String() string

func (*Application) XXX_DiscardUnknown 

func (m *Application) XXX_DiscardUnknown()

func (*Application) XXX_Marshal 

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

func (*Application) XXX_Merge 

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

func (*Application) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Application) XXX_Size 

func (m *Application) XXX_Size() int

func (*Application) XXX_Unmarshal 

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

type ApplicationDeploymentServiceClient 

type ApplicationDeploymentServiceClient interface {
	DeployContainer(ctx context.Context, in *Application, opts ...grpc.CallOption) (*empty.Empty, error)
	DeployVM(ctx context.Context, in *Application, opts ...grpc.CallOption) (*empty.Empty, error)
	Redeploy(ctx context.Context, in *Application, opts ...grpc.CallOption) (*empty.Empty, error)
	Undeploy(ctx context.Context, in *ApplicationID, opts ...grpc.CallOption) (*empty.Empty, error)
}

ApplicationDeploymentServiceClient is the client API for ApplicationDeploymentService service.

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

func NewApplicationDeploymentServiceClient 

func NewApplicationDeploymentServiceClient(cc grpc.ClientConnInterface) ApplicationDeploymentServiceClient

type ApplicationDeploymentServiceServer 

type ApplicationDeploymentServiceServer interface {
	DeployContainer(context.Context, *Application) (*empty.Empty, error)
	DeployVM(context.Context, *Application) (*empty.Empty, error)
	Redeploy(context.Context, *Application) (*empty.Empty, error)
	Undeploy(context.Context, *ApplicationID) (*empty.Empty, error)
}

ApplicationDeploymentServiceServer is the server API for ApplicationDeploymentService service.

type ApplicationID 

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

func (*ApplicationID) Descriptor 

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

func (*ApplicationID) GetId 

func (m *ApplicationID) GetId() string

func (*ApplicationID) ProtoMessage 

func (*ApplicationID) ProtoMessage()

func (*ApplicationID) Reset 

func (m *ApplicationID) Reset()

func (*ApplicationID) String 

func (m *ApplicationID) String() string

func (*ApplicationID) XXX_DiscardUnknown 

func (m *ApplicationID) XXX_DiscardUnknown()

func (*ApplicationID) XXX_Marshal 

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

func (*ApplicationID) XXX_Merge 

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

func (*ApplicationID) XXX_Size 

func (m *ApplicationID) XXX_Size() int

func (*ApplicationID) XXX_Unmarshal 

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

type ApplicationLifecycleServiceClient 

type ApplicationLifecycleServiceClient interface {
	Start(ctx context.Context, in *LifecycleCommand, opts ...grpc.CallOption) (*empty.Empty, error)
	Stop(ctx context.Context, in *LifecycleCommand, opts ...grpc.CallOption) (*empty.Empty, error)
	Restart(ctx context.Context, in *LifecycleCommand, opts ...grpc.CallOption) (*empty.Empty, error)
	GetStatus(ctx context.Context, in *ApplicationID, opts ...grpc.CallOption) (*LifecycleStatus, error)
}

ApplicationLifecycleServiceClient is the client API for ApplicationLifecycleService service.

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

func NewApplicationLifecycleServiceClient 

func NewApplicationLifecycleServiceClient(cc grpc.ClientConnInterface) ApplicationLifecycleServiceClient

type ApplicationLifecycleServiceServer 

type ApplicationLifecycleServiceServer interface {
	Start(context.Context, *LifecycleCommand) (*empty.Empty, error)
	Stop(context.Context, *LifecycleCommand) (*empty.Empty, error)
	Restart(context.Context, *LifecycleCommand) (*empty.Empty, error)
	GetStatus(context.Context, *ApplicationID) (*LifecycleStatus, error)
}

ApplicationLifecycleServiceServer is the server API for ApplicationLifecycleService service.

type Application_HTTPSource 

type Application_HTTPSource struct {
	// Location of VM image or container tarball. In the case of a
	// container, it will be imported with:
	//
	//     docker import ${app.source.uri} ${app.id}:latest
	HttpUri              string   `protobuf:"bytes,1,opt,name=http_uri,json=httpUri,proto3" json:"http_uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Image will be downloaded from an HTTP GET endpoint

func (*Application_HTTPSource) Descriptor 

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

func (*Application_HTTPSource) GetHttpUri 

func (m *Application_HTTPSource) GetHttpUri() string

func (*Application_HTTPSource) ProtoMessage 

func (*Application_HTTPSource) ProtoMessage()

func (*Application_HTTPSource) Reset 

func (m *Application_HTTPSource) Reset()

func (*Application_HTTPSource) String 

func (m *Application_HTTPSource) String() string

func (*Application_HTTPSource) XXX_DiscardUnknown 

func (m *Application_HTTPSource) XXX_DiscardUnknown()

func (*Application_HTTPSource) XXX_Marshal 

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

func (*Application_HTTPSource) XXX_Merge 

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

func (*Application_HTTPSource) XXX_Size 

func (m *Application_HTTPSource) XXX_Size() int

func (*Application_HTTPSource) XXX_Unmarshal 

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

type Application_HttpUri 

type Application_HttpUri struct {
	HttpUri *Application_HTTPSource `protobuf:"bytes,10,opt,name=http_uri,json=httpUri,proto3,oneof"`
}

type Applications 

type Applications struct {
	Applications         []*Application `protobuf:"bytes,1,rep,name=applications,proto3" json:"applications,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Applications) Descriptor 

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

func (*Applications) GetApplications 

func (m *Applications) GetApplications() []*Application

func (*Applications) ProtoMessage 

func (*Applications) ProtoMessage()

func (*Applications) Reset 

func (m *Applications) Reset()

func (*Applications) String 

func (m *Applications) String() string

func (*Applications) XXX_DiscardUnknown 

func (m *Applications) XXX_DiscardUnknown()

func (*Applications) XXX_Marshal 

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

func (*Applications) XXX_Merge 

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

func (*Applications) XXX_Size 

func (m *Applications) XXX_Size() int

func (*Applications) XXX_Unmarshal 

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

type CNIConfiguration 

type CNIConfiguration struct {
	CniConfig            string   `protobuf:"bytes,1,opt,name=cniConfig,proto3" json:"cniConfig,omitempty"`
	InterfaceName        string   `protobuf:"bytes,2,opt,name=interfaceName,proto3" json:"interfaceName,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Args                 string   `protobuf:"bytes,4,opt,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CNIConfiguration stores CNI configuration data

func (*CNIConfiguration) Descriptor 

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

func (*CNIConfiguration) GetArgs 

func (m *CNIConfiguration) GetArgs() string

func (*CNIConfiguration) GetCniConfig 

func (m *CNIConfiguration) GetCniConfig() string

func (*CNIConfiguration) GetInterfaceName 

func (m *CNIConfiguration) GetInterfaceName() string

func (*CNIConfiguration) GetPath 

func (m *CNIConfiguration) GetPath() string

func (*CNIConfiguration) ProtoMessage 

func (*CNIConfiguration) ProtoMessage()

func (*CNIConfiguration) Reset 

func (m *CNIConfiguration) Reset()

func (*CNIConfiguration) String 

func (m *CNIConfiguration) String() string

func (*CNIConfiguration) XXX_DiscardUnknown 

func (m *CNIConfiguration) XXX_DiscardUnknown()

func (*CNIConfiguration) XXX_Marshal 

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

func (*CNIConfiguration) XXX_Merge 

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

func (*CNIConfiguration) XXX_Size 

func (m *CNIConfiguration) XXX_Size() int

func (*CNIConfiguration) XXX_Unmarshal 

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

type ContainerIP 

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

func (*ContainerIP) Descriptor 

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

func (*ContainerIP) GetIp 

func (m *ContainerIP) GetIp() string

func (*ContainerIP) ProtoMessage 

func (*ContainerIP) ProtoMessage()

func (*ContainerIP) Reset 

func (m *ContainerIP) Reset()

func (*ContainerIP) String 

func (m *ContainerIP) String() string

func (*ContainerIP) XXX_DiscardUnknown 

func (m *ContainerIP) XXX_DiscardUnknown()

func (*ContainerIP) XXX_Marshal 

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

func (*ContainerIP) XXX_Merge 

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

func (*ContainerIP) XXX_Size 

func (m *ContainerIP) XXX_Size() int

func (*ContainerIP) XXX_Unmarshal 

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

type ContainerInfo 

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

ContainerInfo represents the state of a running application.

func (*ContainerInfo) Descriptor 

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

func (*ContainerInfo) GetId 

func (m *ContainerInfo) GetId() string

func (*ContainerInfo) ProtoMessage 

func (*ContainerInfo) ProtoMessage()

func (*ContainerInfo) Reset 

func (m *ContainerInfo) Reset()

func (*ContainerInfo) String 

func (m *ContainerInfo) String() string

func (*ContainerInfo) XXX_DiscardUnknown 

func (m *ContainerInfo) XXX_DiscardUnknown()

func (*ContainerInfo) XXX_Marshal 

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

func (*ContainerInfo) XXX_Merge 

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

func (*ContainerInfo) XXX_Size 

func (m *ContainerInfo) XXX_Size() int

func (*ContainerInfo) XXX_Unmarshal 

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

type ControllerVirtualizationAgentClient 

type ControllerVirtualizationAgentClient interface {
	// GetContainerByIP queries an external orchestrator (e.g. Kubernetes) for
	// an application running (not stopped) on the Node making the request with
	// a given (active) Pod IP address. The identity of the Node making the
	// request is determined by the TLS certificate it presents at transport
	// authentication time.
	GetContainerByIP(ctx context.Context, in *ContainerIP, opts ...grpc.CallOption) (*ContainerInfo, error)
}

ControllerVirtualizationAgentClient is the client API for ControllerVirtualizationAgent service.

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

func NewControllerVirtualizationAgentClient 

func NewControllerVirtualizationAgentClient(cc grpc.ClientConnInterface) ControllerVirtualizationAgentClient

type ControllerVirtualizationAgentServer 

type ControllerVirtualizationAgentServer interface {
	// GetContainerByIP queries an external orchestrator (e.g. Kubernetes) for
	// an application running (not stopped) on the Node making the request with
	// a given (active) Pod IP address. The identity of the Node making the
	// request is determined by the TLS certificate it presents at transport
	// authentication time.
	GetContainerByIP(context.Context, *ContainerIP) (*ContainerInfo, error)
}

ControllerVirtualizationAgentServer is the server API for ControllerVirtualizationAgent service.

type LifecycleCommand 

type LifecycleCommand struct {
	Id                   string                   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Cmd                  LifecycleCommand_Command `protobuf:"varint,2,opt,name=cmd,proto3,enum=openness.eva.LifecycleCommand_Command" json:"cmd,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*LifecycleCommand) Descriptor 

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

func (*LifecycleCommand) GetCmd 

func (m *LifecycleCommand) GetCmd() LifecycleCommand_Command

func (*LifecycleCommand) GetId 

func (m *LifecycleCommand) GetId() string

func (*LifecycleCommand) ProtoMessage 

func (*LifecycleCommand) ProtoMessage()

func (*LifecycleCommand) Reset 

func (m *LifecycleCommand) Reset()

func (*LifecycleCommand) String 

func (m *LifecycleCommand) String() string

func (*LifecycleCommand) XXX_DiscardUnknown 

func (m *LifecycleCommand) XXX_DiscardUnknown()

func (*LifecycleCommand) XXX_Marshal 

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

func (*LifecycleCommand) XXX_Merge 

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

func (*LifecycleCommand) XXX_Size 

func (m *LifecycleCommand) XXX_Size() int

func (*LifecycleCommand) XXX_Unmarshal 

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

type LifecycleCommand_Command 

type LifecycleCommand_Command int32
const (
	LifecycleCommand_START   LifecycleCommand_Command = 0
	LifecycleCommand_STOP    LifecycleCommand_Command = 1
	LifecycleCommand_RESTART LifecycleCommand_Command = 2
)

func (LifecycleCommand_Command) EnumDescriptor 

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

func (LifecycleCommand_Command) String 

func (x LifecycleCommand_Command) String() string

type LifecycleStatus 

type LifecycleStatus struct {
	Status               LifecycleStatus_Status `protobuf:"varint,1,opt,name=status,proto3,enum=openness.eva.LifecycleStatus_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*LifecycleStatus) Descriptor 

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

func (*LifecycleStatus) GetStatus 

func (m *LifecycleStatus) GetStatus() LifecycleStatus_Status

func (*LifecycleStatus) ProtoMessage 

func (*LifecycleStatus) ProtoMessage()

func (*LifecycleStatus) Reset 

func (m *LifecycleStatus) Reset()

func (*LifecycleStatus) String 

func (m *LifecycleStatus) String() string

func (*LifecycleStatus) XXX_DiscardUnknown 

func (m *LifecycleStatus) XXX_DiscardUnknown()

func (*LifecycleStatus) XXX_Marshal 

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

func (*LifecycleStatus) XXX_Merge 

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

func (*LifecycleStatus) XXX_Size 

func (m *LifecycleStatus) XXX_Size() int

func (*LifecycleStatus) XXX_Unmarshal 

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

type LifecycleStatus_Status 

type LifecycleStatus_Status int32
const (
	LifecycleStatus_UNKNOWN   LifecycleStatus_Status = 0
	LifecycleStatus_DEPLOYING LifecycleStatus_Status = 1
	LifecycleStatus_READY     LifecycleStatus_Status = 2
	LifecycleStatus_STARTING  LifecycleStatus_Status = 3
	LifecycleStatus_RUNNING   LifecycleStatus_Status = 4
	LifecycleStatus_STOPPING  LifecycleStatus_Status = 5
	LifecycleStatus_STOPPED   LifecycleStatus_Status = 6
	LifecycleStatus_ERROR     LifecycleStatus_Status = 7
)

func (LifecycleStatus_Status) EnumDescriptor 

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

func (LifecycleStatus_Status) String 

func (x LifecycleStatus_Status) String() string

type PortProto 

type PortProto struct {
	Port                 uint32   `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Protocol             string   `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PortProto defines a port and protocol tuple (used for apps & VNFs)

func (*PortProto) Descriptor 

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

func (*PortProto) GetPort 

func (m *PortProto) GetPort() uint32

func (*PortProto) GetProtocol 

func (m *PortProto) GetProtocol() string

func (*PortProto) ProtoMessage 

func (*PortProto) ProtoMessage()

func (*PortProto) Reset 

func (m *PortProto) Reset()

func (*PortProto) String 

func (m *PortProto) String() string

func (*PortProto) XXX_DiscardUnknown 

func (m *PortProto) XXX_DiscardUnknown()

func (*PortProto) XXX_Marshal 

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

func (*PortProto) XXX_Merge 

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

func (*PortProto) XXX_Size 

func (m *PortProto) XXX_Size() int

func (*PortProto) XXX_Unmarshal 

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

type UnimplementedApplicationDeploymentServiceServer 

type UnimplementedApplicationDeploymentServiceServer struct {
}

UnimplementedApplicationDeploymentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedApplicationDeploymentServiceServer) DeployContainer 

func (*UnimplementedApplicationDeploymentServiceServer) DeployContainer(ctx context.Context, req *Application) (*empty.Empty, error)

func (*UnimplementedApplicationDeploymentServiceServer) DeployVM 

func (*UnimplementedApplicationDeploymentServiceServer) DeployVM(ctx context.Context, req *Application) (*empty.Empty, error)

func (*UnimplementedApplicationDeploymentServiceServer) Redeploy 

func (*UnimplementedApplicationDeploymentServiceServer) Redeploy(ctx context.Context, req *Application) (*empty.Empty, error)

func (*UnimplementedApplicationDeploymentServiceServer) Undeploy 

func (*UnimplementedApplicationDeploymentServiceServer) Undeploy(ctx context.Context, req *ApplicationID) (*empty.Empty, error)

type UnimplementedApplicationLifecycleServiceServer 

type UnimplementedApplicationLifecycleServiceServer struct {
}

UnimplementedApplicationLifecycleServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedApplicationLifecycleServiceServer) GetStatus 

func (*UnimplementedApplicationLifecycleServiceServer) GetStatus(ctx context.Context, req *ApplicationID) (*LifecycleStatus, error)

func (*UnimplementedApplicationLifecycleServiceServer) Restart 

func (*UnimplementedApplicationLifecycleServiceServer) Restart(ctx context.Context, req *LifecycleCommand) (*empty.Empty, error)

func (*UnimplementedApplicationLifecycleServiceServer) Start 

func (*UnimplementedApplicationLifecycleServiceServer) Start(ctx context.Context, req *LifecycleCommand) (*empty.Empty, error)

func (*UnimplementedApplicationLifecycleServiceServer) Stop 

func (*UnimplementedApplicationLifecycleServiceServer) Stop(ctx context.Context, req *LifecycleCommand) (*empty.Empty, error)

type UnimplementedControllerVirtualizationAgentServer 

type UnimplementedControllerVirtualizationAgentServer struct {
}

UnimplementedControllerVirtualizationAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedControllerVirtualizationAgentServer) GetContainerByIP 

func (*UnimplementedControllerVirtualizationAgentServer) GetContainerByIP(ctx context.Context, req *ContainerIP) (*ContainerInfo, 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.