structs

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: 9 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 (
	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_client_runner_structs_runner_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Allocation 

type Allocation struct {
	Deployment  *Deployment           `protobuf:"bytes,2,opt,name=deployment,proto3" json:"deployment,omitempty"`
	TaskStates  map[string]*TaskState `` /* 161-byte string literal not displayed */
	Status      Allocation_Status     `protobuf:"varint,6,opt,name=status,proto3,enum=structs.Allocation_Status" json:"status,omitempty"`
	NetworkSpec *NetworkSpec          `protobuf:"bytes,8,opt,name=networkSpec,proto3" json:"networkSpec,omitempty"`
	// contains filtered or unexported fields
}

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) GetDeployment 

func (x *Allocation) GetDeployment() *Deployment

func (*Allocation) GetNetworkSpec 

func (x *Allocation) GetNetworkSpec() *NetworkSpec

func (*Allocation) GetStatus 

func (x *Allocation) GetStatus() Allocation_Status

func (*Allocation) GetTaskStates 

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

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_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 Deployment 

type Deployment struct {
	Name     string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tasks    []*Task `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Sequence int64   `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

func (*Deployment) Copy 

func (d *Deployment) Copy() *Deployment

func (*Deployment) Descriptor deprecated 

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

Deprecated: Use Deployment.ProtoReflect.Descriptor instead.

func (*Deployment) GetName 

func (x *Deployment) GetName() string

func (*Deployment) GetSequence 

func (x *Deployment) GetSequence() int64

func (*Deployment) GetTasks 

func (x *Deployment) GetTasks() []*Task

func (*Deployment) ProtoMessage 

func (*Deployment) ProtoMessage()

func (*Deployment) ProtoReflect 

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

func (*Deployment) Reset 

func (x *Deployment) Reset()

func (*Deployment) String 

func (x *Deployment) String() string

type ExitResult 

type ExitResult struct {
	ExitCode  int64  `protobuf:"varint,1,opt,name=exitCode,proto3" json:"exitCode,omitempty"`
	Signal    int64  `protobuf:"varint,2,opt,name=signal,proto3" json:"signal,omitempty"`
	OomKiller bool   `protobuf:"varint,3,opt,name=oomKiller,proto3" json:"oomKiller,omitempty"`
	Err       string `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*ExitResult) Descriptor deprecated 

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

Deprecated: Use ExitResult.ProtoReflect.Descriptor instead.

func (*ExitResult) GetErr 

func (x *ExitResult) GetErr() string

func (*ExitResult) GetExitCode 

func (x *ExitResult) GetExitCode() int64

func (*ExitResult) GetOomKiller 

func (x *ExitResult) GetOomKiller() bool

func (*ExitResult) GetSignal 

func (x *ExitResult) GetSignal() int64

func (*ExitResult) ProtoMessage 

func (*ExitResult) ProtoMessage()

func (*ExitResult) ProtoReflect 

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

func (*ExitResult) Reset 

func (x *ExitResult) Reset()

func (*ExitResult) String 

func (x *ExitResult) String() string

func (*ExitResult) Successful 

func (r *ExitResult) Successful() bool

type NetworkSpec 

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

func (*NetworkSpec) Descriptor deprecated 

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

Deprecated: Use NetworkSpec.ProtoReflect.Descriptor instead.

func (*NetworkSpec) GetId 

func (x *NetworkSpec) GetId() string

func (*NetworkSpec) GetIp 

func (x *NetworkSpec) GetIp() string

func (*NetworkSpec) ProtoMessage 

func (*NetworkSpec) ProtoMessage()

func (*NetworkSpec) ProtoReflect 

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

func (*NetworkSpec) Reset 

func (x *NetworkSpec) Reset()

func (*NetworkSpec) String 

func (x *NetworkSpec) 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"`
	Name        string                  `protobuf:"bytes,8,opt,name=name,proto3" json:"name,omitempty"`
	Data        map[string]string       `` /* 149-byte string literal not displayed */
	Volumes     map[string]*Task_Volume `` /* 156-byte string literal not displayed */
	Batch       bool                    `protobuf:"varint,15,opt,name=batch,proto3" json:"batch,omitempty"`
	Metadata    map[string]string       `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Task) Copy 

func (d *Task) Copy() *Task

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) GetMetadata 

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

func (*Task) GetName 

func (x *Task) GetName() string

func (*Task) GetSecurityOpt 

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

func (*Task) GetTag 

func (x *Task) GetTag() string

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 TaskHandle 

type TaskHandle struct {
	ContainerID string              `protobuf:"bytes,1,opt,name=containerID,proto3" json:"containerID,omitempty"`
	Network     *TaskHandle_Network `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"`
	Id          string              `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskHandle) Descriptor deprecated 

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

Deprecated: Use TaskHandle.ProtoReflect.Descriptor instead.

func (*TaskHandle) GetContainerID 

func (x *TaskHandle) GetContainerID() string

func (*TaskHandle) GetId 

func (x *TaskHandle) GetId() string

func (*TaskHandle) GetNetwork 

func (x *TaskHandle) GetNetwork() *TaskHandle_Network

func (*TaskHandle) ProtoMessage 

func (*TaskHandle) ProtoMessage()

func (*TaskHandle) ProtoReflect 

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

func (*TaskHandle) Reset 

func (x *TaskHandle) Reset()

func (*TaskHandle) String 

func (x *TaskHandle) String() string

type TaskHandle_Network 

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

func (*TaskHandle_Network) Descriptor deprecated 

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

Deprecated: Use TaskHandle_Network.ProtoReflect.Descriptor instead.

func (*TaskHandle_Network) GetIp 

func (x *TaskHandle_Network) GetIp() string

func (*TaskHandle_Network) ProtoMessage 

func (*TaskHandle_Network) ProtoMessage()

func (*TaskHandle_Network) ProtoReflect 

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

func (*TaskHandle_Network) Reset 

func (x *TaskHandle_Network) Reset()

func (*TaskHandle_Network) String 

func (x *TaskHandle_Network) String() string

type TaskState 

type TaskState struct {
	State    TaskState_State    `protobuf:"varint,1,opt,name=state,proto3,enum=structs.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"`
	Events   []*TaskState_Event `protobuf:"bytes,5,rep,name=events,proto3" json:"events,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 NewTaskState 

func NewTaskState() *TaskState

func (*TaskState) Descriptor deprecated 

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

Deprecated: Use TaskState.ProtoReflect.Descriptor instead.

func (*TaskState) GetEvents 

func (x *TaskState) GetEvents() []*TaskState_Event

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_Event 

type TaskState_Event struct {
	Type    string               `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Details map[string]string    `` /* 155-byte string literal not displayed */
	Time    *timestamp.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func NewTaskEvent 

func NewTaskEvent(typ string) *TaskState_Event

func (*TaskState_Event) Descriptor deprecated 

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

Deprecated: Use TaskState_Event.ProtoReflect.Descriptor instead.

func (*TaskState_Event) FailsTask 

func (t *TaskState_Event) FailsTask() bool

func (*TaskState_Event) GetDetails 

func (x *TaskState_Event) GetDetails() map[string]string

func (*TaskState_Event) GetTime 

func (x *TaskState_Event) GetTime() *timestamp.Timestamp

func (*TaskState_Event) GetType 

func (x *TaskState_Event) GetType() string

func (*TaskState_Event) ProtoMessage 

func (*TaskState_Event) ProtoMessage()

func (*TaskState_Event) ProtoReflect 

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

func (*TaskState_Event) Reset 

func (x *TaskState_Event) Reset()

func (*TaskState_Event) SetExitCode 

func (t *TaskState_Event) SetExitCode(c int64) *TaskState_Event

func (*TaskState_Event) SetFailsTask 

func (t *TaskState_Event) SetFailsTask() *TaskState_Event

func (*TaskState_Event) SetSignal 

func (t *TaskState_Event) SetSignal(s int64) *TaskState_Event

func (*TaskState_Event) String 

func (x *TaskState_Event) 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_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

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.