proto

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2023 License: MPL-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TaskStarted       = "Started"
	TaskTerminated    = "Terminated"
	TaskRestarting    = "Restarting"
	TaskNotRestarting = "Not-restarting"
)

Variables

View Source 
var (
	Allocation_Status_name = map[int32]string{
		0: "Pending",
		1: "Running",
		2: "Complete",
		3: "Failed",
	}
	Allocation_Status_value = map[string]int32{
		"Pending":  0,
		"Running":  1,
		"Complete": 2,
		"Failed":   3,
	}
)

Enum value maps for Allocation_Status.

View Source 
var (
	Allocation_DesiredStatus_name = map[int32]string{
		0: "Run",
		1: "Stop",
	}
	Allocation_DesiredStatus_value = map[string]int32{
		"Run":  0,
		"Stop": 1,
	}
)

Enum value maps for Allocation_DesiredStatus.

View Source 
var (
	TaskState_State_name = map[int32]string{
		0: "Pending",
		1: "Running",
		2: "Dead",
	}
	TaskState_State_value = map[string]int32{
		"Pending": 0,
		"Running": 1,
		"Dead":    2,
	}
)

Enum value maps for TaskState_State.

View Source 
var File_internal_server_proto_vesta_proto protoreflect.FileDescriptor
View Source 
var VestaService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.VestaService",
	HandlerType: (*VestaServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Apply",
			Handler:    _VestaService_Apply_Handler,
		},
		{
			MethodName: "Destroy",
			Handler:    _VestaService_Destroy_Handler,
		},
		{
			MethodName: "DeploymentList",
			Handler:    _VestaService_DeploymentList_Handler,
		},
		{
			MethodName: "DeploymentStatus",
			Handler:    _VestaService_DeploymentStatus_Handler,
		},
		{
			MethodName: "CatalogList",
			Handler:    _VestaService_CatalogList_Handler,
		},
		{
			MethodName: "CatalogInspect",
			Handler:    _VestaService_CatalogInspect_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/server/proto/vesta.proto",
}

VestaService_ServiceDesc is the grpc.ServiceDesc for VestaService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterVestaServiceServer 

func RegisterVestaServiceServer(s grpc.ServiceRegistrar, srv VestaServiceServer)

Types

type Allocation 

type Allocation struct {

	// id of the allocation
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// node to which the allocation is assigned
	NodeId string `protobuf:"bytes,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// tasks to run on the allocation
	Tasks map[string]*Task `` /* 151-byte string literal not displayed */
	// state of each of the tasks
	TaskStates map[string]*TaskState `` /* 161-byte string literal not displayed */
	// status of the allocation
	Status Allocation_Status `protobuf:"varint,5,opt,name=status,proto3,enum=proto.Allocation_Status" json:"status,omitempty"`
	// desired status of the allocation
	DesiredStatus Allocation_DesiredStatus `protobuf:"varint,7,opt,name=desiredStatus,proto3,enum=proto.Allocation_DesiredStatus" json:"desiredStatus,omitempty"`
	// modify index sequence number
	Sequence   int64  `protobuf:"varint,8,opt,name=sequence,proto3" json:"sequence,omitempty"`
	InputState []byte `protobuf:"bytes,9,opt,name=inputState,proto3" json:"inputState,omitempty"`
	// contains filtered or unexported fields
}

Allocation represents an allocation of a deployment

func (*Allocation) Copy 

func (a *Allocation) Copy() *Allocation

func (*Allocation) Descriptor deprecated 

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

Deprecated: Use Allocation.ProtoReflect.Descriptor instead.

func (*Allocation) GetDesiredStatus 

func (x *Allocation) GetDesiredStatus() Allocation_DesiredStatus

func (*Allocation) GetId 

func (x *Allocation) GetId() string

func (*Allocation) GetInputState 

func (x *Allocation) GetInputState() []byte

func (*Allocation) GetNodeId 

func (x *Allocation) GetNodeId() string

func (*Allocation) GetSequence 

func (x *Allocation) GetSequence() int64

func (*Allocation) GetStatus 

func (x *Allocation) GetStatus() Allocation_Status

func (*Allocation) GetTaskStates 

func (x *Allocation) GetTaskStates() map[string]*TaskState

func (*Allocation) GetTasks 

func (x *Allocation) GetTasks() map[string]*Task

func (*Allocation) ProtoMessage 

func (*Allocation) ProtoMessage()

func (*Allocation) ProtoReflect 

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

func (*Allocation) Reset 

func (x *Allocation) Reset()

func (*Allocation) String 

func (x *Allocation) String() string

type Allocation_DesiredStatus 

type Allocation_DesiredStatus int32
const (
	Allocation_Run  Allocation_DesiredStatus = 0
	Allocation_Stop Allocation_DesiredStatus = 1
)

func (Allocation_DesiredStatus) Descriptor 

func (Allocation_DesiredStatus) Descriptor() protoreflect.EnumDescriptor

func (Allocation_DesiredStatus) Enum 

func (x Allocation_DesiredStatus) Enum() *Allocation_DesiredStatus

func (Allocation_DesiredStatus) EnumDescriptor deprecated 

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

Deprecated: Use Allocation_DesiredStatus.Descriptor instead.

func (Allocation_DesiredStatus) Number 

func (x Allocation_DesiredStatus) Number() protoreflect.EnumNumber

func (Allocation_DesiredStatus) String 

func (x Allocation_DesiredStatus) String() string

func (Allocation_DesiredStatus) Type 

func (Allocation_DesiredStatus) Type() protoreflect.EnumType

type Allocation_Status 

type Allocation_Status int32
const (
	Allocation_Pending  Allocation_Status = 0
	Allocation_Running  Allocation_Status = 1
	Allocation_Complete Allocation_Status = 2
	Allocation_Failed   Allocation_Status = 3
)

func (Allocation_Status) Descriptor 

func (Allocation_Status) Descriptor() protoreflect.EnumDescriptor

func (Allocation_Status) Enum 

func (x Allocation_Status) Enum() *Allocation_Status

func (Allocation_Status) EnumDescriptor deprecated 

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

Deprecated: Use Allocation_Status.Descriptor instead.

func (Allocation_Status) Number 

func (x Allocation_Status) Number() protoreflect.EnumNumber

func (Allocation_Status) String 

func (x Allocation_Status) String() string

func (Allocation_Status) Type 

func (Allocation_Status) Type() protoreflect.EnumType

type ApplyRequest 

type ApplyRequest struct {

	// id name of the action
	Action string `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	// input for the action
	Input []byte `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	// name of the allocation to modify
	AllocationId string `protobuf:"bytes,3,opt,name=allocationId,proto3" json:"allocationId,omitempty"`
	Metrics      bool   `protobuf:"varint,4,opt,name=metrics,proto3" json:"metrics,omitempty"`
	Chain        string `protobuf:"bytes,5,opt,name=chain,proto3" json:"chain,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyRequest) Descriptor deprecated 

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

Deprecated: Use ApplyRequest.ProtoReflect.Descriptor instead.

func (*ApplyRequest) GetAction 

func (x *ApplyRequest) GetAction() string

func (*ApplyRequest) GetAllocationId 

func (x *ApplyRequest) GetAllocationId() string

func (*ApplyRequest) GetChain 

func (x *ApplyRequest) GetChain() string

func (*ApplyRequest) GetInput 

func (x *ApplyRequest) GetInput() []byte

func (*ApplyRequest) GetMetrics 

func (x *ApplyRequest) GetMetrics() bool

func (*ApplyRequest) ProtoMessage 

func (*ApplyRequest) ProtoMessage()

func (*ApplyRequest) ProtoReflect 

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

func (*ApplyRequest) Reset 

func (x *ApplyRequest) Reset()

func (*ApplyRequest) String 

func (x *ApplyRequest) String() string

type ApplyResponse 

type ApplyResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyResponse) Descriptor deprecated 

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

Deprecated: Use ApplyResponse.ProtoReflect.Descriptor instead.

func (*ApplyResponse) GetId 

func (x *ApplyResponse) GetId() string

func (*ApplyResponse) ProtoMessage 

func (*ApplyResponse) ProtoMessage()

func (*ApplyResponse) ProtoReflect 

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

func (*ApplyResponse) Reset 

func (x *ApplyResponse) Reset()

func (*ApplyResponse) String 

func (x *ApplyResponse) String() string

type CatalogInspectRequest 

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

func (*CatalogInspectRequest) Descriptor deprecated 

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

Deprecated: Use CatalogInspectRequest.ProtoReflect.Descriptor instead.

func (*CatalogInspectRequest) GetName 

func (x *CatalogInspectRequest) GetName() string

func (*CatalogInspectRequest) ProtoMessage 

func (*CatalogInspectRequest) ProtoMessage()

func (*CatalogInspectRequest) ProtoReflect 

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

func (*CatalogInspectRequest) Reset 

func (x *CatalogInspectRequest) Reset()

func (*CatalogInspectRequest) String 

func (x *CatalogInspectRequest) String() string

type CatalogInspectResponse 

type CatalogInspectResponse struct {
	Item *Item `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

func (*CatalogInspectResponse) Descriptor deprecated 

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

Deprecated: Use CatalogInspectResponse.ProtoReflect.Descriptor instead.

func (*CatalogInspectResponse) GetItem 

func (x *CatalogInspectResponse) GetItem() *Item

func (*CatalogInspectResponse) ProtoMessage 

func (*CatalogInspectResponse) ProtoMessage()

func (*CatalogInspectResponse) ProtoReflect 

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

func (*CatalogInspectResponse) Reset 

func (x *CatalogInspectResponse) Reset()

func (*CatalogInspectResponse) String 

func (x *CatalogInspectResponse) String() string

type CatalogListRequest 

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

func (*CatalogListRequest) Descriptor deprecated 

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

Deprecated: Use CatalogListRequest.ProtoReflect.Descriptor instead.

func (*CatalogListRequest) ProtoMessage 

func (*CatalogListRequest) ProtoMessage()

func (*CatalogListRequest) ProtoReflect 

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

func (*CatalogListRequest) Reset 

func (x *CatalogListRequest) Reset()

func (*CatalogListRequest) String 

func (x *CatalogListRequest) String() string

type CatalogListResponse 

type CatalogListResponse struct {
	Plugins []string `protobuf:"bytes,1,rep,name=plugins,proto3" json:"plugins,omitempty"`
	// contains filtered or unexported fields
}

func (*CatalogListResponse) Descriptor deprecated 

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

Deprecated: Use CatalogListResponse.ProtoReflect.Descriptor instead.

func (*CatalogListResponse) GetPlugins 

func (x *CatalogListResponse) GetPlugins() []string

func (*CatalogListResponse) ProtoMessage 

func (*CatalogListResponse) ProtoMessage()

func (*CatalogListResponse) ProtoReflect 

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

func (*CatalogListResponse) Reset 

func (x *CatalogListResponse) Reset()

func (*CatalogListResponse) String 

func (x *CatalogListResponse) String() string

type DeploymentStatusRequest 

type DeploymentStatusRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentStatusRequest) Descriptor deprecated 

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

Deprecated: Use DeploymentStatusRequest.ProtoReflect.Descriptor instead.

func (*DeploymentStatusRequest) GetId 

func (x *DeploymentStatusRequest) GetId() string

func (*DeploymentStatusRequest) ProtoMessage 

func (*DeploymentStatusRequest) ProtoMessage()

func (*DeploymentStatusRequest) ProtoReflect 

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

func (*DeploymentStatusRequest) Reset 

func (x *DeploymentStatusRequest) Reset()

func (*DeploymentStatusRequest) String 

func (x *DeploymentStatusRequest) String() string

type DeploymentStatusResponse 

type DeploymentStatusResponse struct {
	Allocation *Allocation `protobuf:"bytes,1,opt,name=allocation,proto3" json:"allocation,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentStatusResponse) Descriptor deprecated 

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

Deprecated: Use DeploymentStatusResponse.ProtoReflect.Descriptor instead.

func (*DeploymentStatusResponse) GetAllocation 

func (x *DeploymentStatusResponse) GetAllocation() *Allocation

func (*DeploymentStatusResponse) ProtoMessage 

func (*DeploymentStatusResponse) ProtoMessage()

func (*DeploymentStatusResponse) ProtoReflect 

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

func (*DeploymentStatusResponse) Reset 

func (x *DeploymentStatusResponse) Reset()

func (*DeploymentStatusResponse) String 

func (x *DeploymentStatusResponse) String() string

type DestroyRequest 

type DestroyRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyRequest) Descriptor deprecated 

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

Deprecated: Use DestroyRequest.ProtoReflect.Descriptor instead.

func (*DestroyRequest) GetId 

func (x *DestroyRequest) GetId() string

func (*DestroyRequest) ProtoMessage 

func (*DestroyRequest) ProtoMessage()

func (*DestroyRequest) ProtoReflect 

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

func (*DestroyRequest) Reset 

func (x *DestroyRequest) Reset()

func (*DestroyRequest) String 

func (x *DestroyRequest) String() string

type DestroyResponse 

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

func (*DestroyResponse) Descriptor deprecated 

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

Deprecated: Use DestroyResponse.ProtoReflect.Descriptor instead.

func (*DestroyResponse) ProtoMessage 

func (*DestroyResponse) ProtoMessage()

func (*DestroyResponse) ProtoReflect 

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

func (*DestroyResponse) Reset 

func (x *DestroyResponse) Reset()

func (*DestroyResponse) String 

func (x *DestroyResponse) String() string

type Item 

type Item struct {
	Name   string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Fields []*Item_Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	Chains []string      `protobuf:"bytes,3,rep,name=chains,proto3" json:"chains,omitempty"`
	// contains filtered or unexported fields
}

Provisonal name, item is an item on the catalog

func (*Item) Descriptor deprecated 

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

Deprecated: Use Item.ProtoReflect.Descriptor instead.

func (*Item) GetChains 

func (x *Item) GetChains() []string

func (*Item) GetFields 

func (x *Item) GetFields() []*Item_Field

func (*Item) GetName 

func (x *Item) GetName() string

func (*Item) ProtoMessage 

func (*Item) ProtoMessage()

func (*Item) ProtoReflect 

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

func (*Item) Reset 

func (x *Item) Reset()

func (*Item) String 

func (x *Item) String() string

type Item_Field 

type Item_Field struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type        string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Default     string `protobuf:"bytes,4,opt,name=default,proto3" json:"default,omitempty"`
	Required    bool   `protobuf:"varint,5,opt,name=required,proto3" json:"required,omitempty"`
	// contains filtered or unexported fields
}

func (*Item_Field) Descriptor deprecated 

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

Deprecated: Use Item_Field.ProtoReflect.Descriptor instead.

func (*Item_Field) GetDefault 

func (x *Item_Field) GetDefault() string

func (*Item_Field) GetDescription 

func (x *Item_Field) GetDescription() string

func (*Item_Field) GetName 

func (x *Item_Field) GetName() string

func (*Item_Field) GetRequired 

func (x *Item_Field) GetRequired() bool

func (*Item_Field) GetType 

func (x *Item_Field) GetType() string

func (*Item_Field) ProtoMessage 

func (*Item_Field) ProtoMessage()

func (*Item_Field) ProtoReflect 

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

func (*Item_Field) Reset 

func (x *Item_Field) Reset()

func (*Item_Field) String 

func (x *Item_Field) String() string

type ListDeploymentRequest 

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

func (*ListDeploymentRequest) Descriptor deprecated 

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

Deprecated: Use ListDeploymentRequest.ProtoReflect.Descriptor instead.

func (*ListDeploymentRequest) ProtoMessage 

func (*ListDeploymentRequest) ProtoMessage()

func (*ListDeploymentRequest) ProtoReflect 

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

func (*ListDeploymentRequest) Reset 

func (x *ListDeploymentRequest) Reset()

func (*ListDeploymentRequest) String 

func (x *ListDeploymentRequest) String() string

type ListDeploymentResponse 

type ListDeploymentResponse struct {
	Allocations []*Allocation `protobuf:"bytes,1,rep,name=allocations,proto3" json:"allocations,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDeploymentResponse) Descriptor deprecated 

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

Deprecated: Use ListDeploymentResponse.ProtoReflect.Descriptor instead.

func (*ListDeploymentResponse) GetAllocations 

func (x *ListDeploymentResponse) GetAllocations() []*Allocation

func (*ListDeploymentResponse) ProtoMessage 

func (*ListDeploymentResponse) ProtoMessage()

func (*ListDeploymentResponse) ProtoReflect 

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

func (*ListDeploymentResponse) Reset 

func (x *ListDeploymentResponse) Reset()

func (*ListDeploymentResponse) String 

func (x *ListDeploymentResponse) String() string

type Node 

type Node struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Datacenter string `protobuf:"bytes,2,opt,name=datacenter,proto3" json:"datacenter,omitempty"`
	Name       string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Node1 is a node that can allocate resources

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetDatacenter 

func (x *Node) GetDatacenter() string

func (*Node) GetId 

func (x *Node) GetId() string

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type Task 

type Task struct {
	Image       string            `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	Tag         string            `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	Args        []string          `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	Env         map[string]string `` /* 147-byte string literal not displayed */
	Labels      map[string]string `` /* 153-byte string literal not displayed */
	SecurityOpt []string          `protobuf:"bytes,7,rep,name=securityOpt,proto3" json:"securityOpt,omitempty"`
	// list of data access for this file
	Data      map[string]string       `` /* 149-byte string literal not displayed */
	Volumes   map[string]*Task_Volume `` /* 156-byte string literal not displayed */
	Telemetry *Task_Telemetry         `protobuf:"bytes,12,opt,name=telemetry,proto3" json:"telemetry,omitempty"`
	Batch     bool                    `protobuf:"varint,14,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

Task represents an single container process

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetArgs 

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

func (*Task) GetBatch 

func (x *Task) GetBatch() bool

func (*Task) GetData 

func (x *Task) GetData() map[string]string

func (*Task) GetEnv 

func (x *Task) GetEnv() map[string]string

func (*Task) GetImage 

func (x *Task) GetImage() string

func (*Task) GetLabels 

func (x *Task) GetLabels() map[string]string

func (*Task) GetSecurityOpt 

func (x *Task) GetSecurityOpt() []string

func (*Task) GetTag 

func (x *Task) GetTag() string

func (*Task) GetTelemetry 

func (x *Task) GetTelemetry() *Task_Telemetry

func (*Task) GetVolumes 

func (x *Task) GetVolumes() map[string]*Task_Volume

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskState 

type TaskState struct {
	State    TaskState_State `protobuf:"varint,1,opt,name=state,proto3,enum=proto.TaskState_State" json:"state,omitempty"`
	Failed   bool            `protobuf:"varint,2,opt,name=failed,proto3" json:"failed,omitempty"`
	Restarts uint64          `protobuf:"varint,3,opt,name=restarts,proto3" json:"restarts,omitempty"`
	Id       string          `protobuf:"bytes,6,opt,name=id,proto3" json:"id,omitempty"`
	Killing  bool            `protobuf:"varint,7,opt,name=killing,proto3" json:"killing,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskState) Descriptor deprecated 

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

Deprecated: Use TaskState.ProtoReflect.Descriptor instead.

func (*TaskState) GetFailed 

func (x *TaskState) GetFailed() bool

func (*TaskState) GetId 

func (x *TaskState) GetId() string

func (*TaskState) GetKilling 

func (x *TaskState) GetKilling() bool

func (*TaskState) GetRestarts 

func (x *TaskState) GetRestarts() uint64

func (*TaskState) GetState 

func (x *TaskState) GetState() TaskState_State

func (*TaskState) ProtoMessage 

func (*TaskState) ProtoMessage()

func (*TaskState) ProtoReflect 

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

func (*TaskState) Reset 

func (x *TaskState) Reset()

func (*TaskState) String 

func (x *TaskState) String() string

type TaskState_State 

type TaskState_State int32
const (
	TaskState_Pending TaskState_State = 0
	TaskState_Running TaskState_State = 1
	TaskState_Dead    TaskState_State = 2
)

func (TaskState_State) Descriptor 

func (TaskState_State) Descriptor() protoreflect.EnumDescriptor

func (TaskState_State) Enum 

func (x TaskState_State) Enum() *TaskState_State

func (TaskState_State) EnumDescriptor deprecated 

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

Deprecated: Use TaskState_State.Descriptor instead.

func (TaskState_State) Number 

func (x TaskState_State) Number() protoreflect.EnumNumber

func (TaskState_State) String 

func (x TaskState_State) String() string

func (TaskState_State) Type 

func (TaskState_State) Type() protoreflect.EnumType

type Task_Telemetry 

type Task_Telemetry struct {
	Port uint64 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*Task_Telemetry) Descriptor deprecated 

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

Deprecated: Use Task_Telemetry.ProtoReflect.Descriptor instead.

func (*Task_Telemetry) GetPath 

func (x *Task_Telemetry) GetPath() string

func (*Task_Telemetry) GetPort 

func (x *Task_Telemetry) GetPort() uint64

func (*Task_Telemetry) ProtoMessage 

func (*Task_Telemetry) ProtoMessage()

func (*Task_Telemetry) ProtoReflect 

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

func (*Task_Telemetry) Reset 

func (x *Task_Telemetry) Reset()

func (*Task_Telemetry) String 

func (x *Task_Telemetry) String() string

type Task_Volume 

type Task_Volume struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*Task_Volume) Descriptor deprecated 

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

Deprecated: Use Task_Volume.ProtoReflect.Descriptor instead.

func (*Task_Volume) GetPath 

func (x *Task_Volume) GetPath() string

func (*Task_Volume) ProtoMessage 

func (*Task_Volume) ProtoMessage()

func (*Task_Volume) ProtoReflect 

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

func (*Task_Volume) Reset 

func (x *Task_Volume) Reset()

func (*Task_Volume) String 

func (x *Task_Volume) String() string

type UnimplementedVestaServiceServer 

type UnimplementedVestaServiceServer struct {
}

UnimplementedVestaServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedVestaServiceServer) Apply 

func (UnimplementedVestaServiceServer) Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)

func (UnimplementedVestaServiceServer) CatalogInspect 

func (UnimplementedVestaServiceServer) CatalogInspect(context.Context, *CatalogInspectRequest) (*CatalogInspectResponse, error)

func (UnimplementedVestaServiceServer) CatalogList 

func (UnimplementedVestaServiceServer) CatalogList(context.Context, *CatalogListRequest) (*CatalogListResponse, error)

func (UnimplementedVestaServiceServer) DeploymentList 

func (UnimplementedVestaServiceServer) DeploymentList(context.Context, *ListDeploymentRequest) (*ListDeploymentResponse, error)

func (UnimplementedVestaServiceServer) DeploymentStatus 

func (UnimplementedVestaServiceServer) DeploymentStatus(context.Context, *DeploymentStatusRequest) (*DeploymentStatusResponse, error)

func (UnimplementedVestaServiceServer) Destroy 

func (UnimplementedVestaServiceServer) Destroy(context.Context, *DestroyRequest) (*DestroyResponse, error)

type UnsafeVestaServiceServer 

type UnsafeVestaServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeVestaServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VestaServiceServer will result in compilation errors.

type VestaServiceClient 

type VestaServiceClient interface {
	Apply(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)
	Destroy(ctx context.Context, in *DestroyRequest, opts ...grpc.CallOption) (*DestroyResponse, error)
	DeploymentList(ctx context.Context, in *ListDeploymentRequest, opts ...grpc.CallOption) (*ListDeploymentResponse, error)
	DeploymentStatus(ctx context.Context, in *DeploymentStatusRequest, opts ...grpc.CallOption) (*DeploymentStatusResponse, error)
	CatalogList(ctx context.Context, in *CatalogListRequest, opts ...grpc.CallOption) (*CatalogListResponse, error)
	CatalogInspect(ctx context.Context, in *CatalogInspectRequest, opts ...grpc.CallOption) (*CatalogInspectResponse, error)
}

VestaServiceClient is the client API for VestaService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewVestaServiceClient 

func NewVestaServiceClient(cc grpc.ClientConnInterface) VestaServiceClient

type VestaServiceServer 

type VestaServiceServer interface {
	Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)
	Destroy(context.Context, *DestroyRequest) (*DestroyResponse, error)
	DeploymentList(context.Context, *ListDeploymentRequest) (*ListDeploymentResponse, error)
	DeploymentStatus(context.Context, *DeploymentStatusRequest) (*DeploymentStatusResponse, error)
	CatalogList(context.Context, *CatalogListRequest) (*CatalogListResponse, error)
	CatalogInspect(context.Context, *CatalogInspectRequest) (*CatalogInspectResponse, error)
	// contains filtered or unexported methods
}

VestaServiceServer is the server API for VestaService service. All implementations must embed UnimplementedVestaServiceServer for forward compatibility

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.