types

package
v0.1.9 Latest Latest
Warning

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

 Go to latest Published: Mar 20, 2017 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package types is a generated protocol buffer package.

It is generated from these files: 

application.proto
raft.proto

It has these top-level messages: 

Application
Version
Container
Docker
Parameter
PortMapping
Volume
KillPolicy
UpdatePolicy
HealthCheck
Slot
RestartPolicy
Task
OfferAllocatorItem
StateMachine
State
InternalRaftRequest
StoreAction
Framework
Node

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApplication = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApplication   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRaft = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaft   = fmt.Errorf("proto: integer overflow")
)
View Source 
var StoreActionKind_name = map[int32]string{
	0: "UNKNOWN",
	1: "STORE_ACTION_CREATE",
	2: "STORE_ACTION_UPDATE",
	3: "STORE_ACTION_REMOVE",
}
View Source 
var StoreActionKind_value = map[string]int32{
	"UNKNOWN":             0,
	"STORE_ACTION_CREATE": 1,
	"STORE_ACTION_UPDATE": 2,
	"STORE_ACTION_REMOVE": 3,
}

Functions

This section is empty.

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         *Version      `protobuf:"bytes,3,opt,name=version" json:"version,omitempty"`
	ProposedVersion *Version      `protobuf:"bytes,4,opt,name=proposedVersion" json:"proposedVersion,omitempty"`
	ClusterID       string        `protobuf:"bytes,5,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
	StateMachine    *StateMachine `protobuf:"bytes,6,opt,name=stateMachine" json:"stateMachine,omitempty"`
	CreatedAt       int64         `protobuf:"varint,7,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	UpdatedAt       int64         `protobuf:"varint,8,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	State           string        `protobuf:"bytes,9,opt,name=State,proto3" json:"State,omitempty"`
}

func NewPopulatedApplication 

func NewPopulatedApplication(r randyApplication, easy bool) *Application

func (*Application) Descriptor 

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

func (*Application) Equal 

func (this *Application) Equal(that interface{}) bool

func (*Application) GoString 

func (this *Application) GoString() string

func (*Application) Marshal 

func (m *Application) Marshal() (dAtA []byte, err error)

func (*Application) MarshalTo 

func (m *Application) MarshalTo(dAtA []byte) (int, error)

func (*Application) ProtoMessage 

func (*Application) ProtoMessage()

func (*Application) Reset 

func (m *Application) Reset()

func (*Application) Size 

func (m *Application) Size() (n int)

func (*Application) String 

func (m *Application) String() string

func (*Application) Unmarshal 

func (m *Application) Unmarshal(dAtA []byte) error

func (*Application) VerboseEqual 

func (this *Application) VerboseEqual(that interface{}) error

type Container 

type Container struct {
	Type    string    `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Docker  *Docker   `protobuf:"bytes,2,opt,name=docker" json:"docker,omitempty"`
	Volumes []*Volume `protobuf:"bytes,3,rep,name=volumes" json:"volumes,omitempty"`
}

func NewPopulatedContainer 

func NewPopulatedContainer(r randyApplication, easy bool) *Container

func (*Container) Descriptor 

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

func (*Container) Equal 

func (this *Container) Equal(that interface{}) bool

func (*Container) GoString 

func (this *Container) GoString() string

func (*Container) Marshal 

func (m *Container) Marshal() (dAtA []byte, err error)

func (*Container) MarshalTo 

func (m *Container) MarshalTo(dAtA []byte) (int, error)

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) Reset 

func (m *Container) Reset()

func (*Container) Size 

func (m *Container) Size() (n int)

func (*Container) String 

func (m *Container) String() string

func (*Container) Unmarshal 

func (m *Container) Unmarshal(dAtA []byte) error

func (*Container) VerboseEqual 

func (this *Container) VerboseEqual(that interface{}) error

type Docker 

type Docker struct {
	ForcePullImage bool           `protobuf:"varint,1,opt,name=forcePullImage,proto3" json:"forcePullImage,omitempty"`
	Image          string         `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Network        string         `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"`
	Parameters     []*Parameter   `protobuf:"bytes,4,rep,name=parameters" json:"parameters,omitempty"`
	PortMappings   []*PortMapping `protobuf:"bytes,5,rep,name=portMappings" json:"portMappings,omitempty"`
	Privileged     bool           `protobuf:"varint,6,opt,name=privileged,proto3" json:"privileged,omitempty"`
}

func NewPopulatedDocker 

func NewPopulatedDocker(r randyApplication, easy bool) *Docker

func (*Docker) Descriptor 

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

func (*Docker) Equal 

func (this *Docker) Equal(that interface{}) bool

func (*Docker) GoString 

func (this *Docker) GoString() string

func (*Docker) Marshal 

func (m *Docker) Marshal() (dAtA []byte, err error)

func (*Docker) MarshalTo 

func (m *Docker) MarshalTo(dAtA []byte) (int, error)

func (*Docker) ProtoMessage 

func (*Docker) ProtoMessage()

func (*Docker) Reset 

func (m *Docker) Reset()

func (*Docker) Size 

func (m *Docker) Size() (n int)

func (*Docker) String 

func (m *Docker) String() string

func (*Docker) Unmarshal 

func (m *Docker) Unmarshal(dAtA []byte) error

func (*Docker) VerboseEqual 

func (this *Docker) VerboseEqual(that interface{}) error

type Framework 

type Framework struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func NewPopulatedFramework 

func NewPopulatedFramework(r randyRaft, easy bool) *Framework

func (*Framework) Descriptor 

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

func (*Framework) Equal 

func (this *Framework) Equal(that interface{}) bool

func (*Framework) GoString 

func (this *Framework) GoString() string

func (*Framework) Marshal 

func (m *Framework) Marshal() (dAtA []byte, err error)

func (*Framework) MarshalTo 

func (m *Framework) MarshalTo(dAtA []byte) (int, error)

func (*Framework) ProtoMessage 

func (*Framework) ProtoMessage()

func (*Framework) Reset 

func (m *Framework) Reset()

func (*Framework) Size 

func (m *Framework) Size() (n int)

func (*Framework) String 

func (m *Framework) String() string

func (*Framework) Unmarshal 

func (m *Framework) Unmarshal(dAtA []byte) error

func (*Framework) VerboseEqual 

func (this *Framework) VerboseEqual(that interface{}) error

type HealthCheck 

type HealthCheck struct {
	ID                  string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address             string  `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Protocol            string  `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Port                int32   `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	PortIndex           int32   `protobuf:"varint,5,opt,name=portIndex,proto3" json:"portIndex,omitempty"`
	PortName            string  `protobuf:"bytes,6,opt,name=portName,proto3" json:"portName,omitempty"`
	Value               string  `protobuf:"bytes,7,opt,name=value,proto3" json:"value,omitempty"`
	Path                string  `protobuf:"bytes,8,opt,name=path,proto3" json:"path,omitempty"`
	ConsecutiveFailures uint32  `protobuf:"varint,9,opt,name=consecutiveFailures,proto3" json:"consecutiveFailures,omitempty"`
	GracePeriodSeconds  float64 `protobuf:"fixed64,10,opt,name=gracePeriodSeconds,proto3" json:"gracePeriodSeconds,omitempty"`
	IntervalSeconds     float64 `protobuf:"fixed64,11,opt,name=intervalSeconds,proto3" json:"intervalSeconds,omitempty"`
	TimeoutSeconds      float64 `protobuf:"fixed64,12,opt,name=timeoutSeconds,proto3" json:"timeoutSeconds,omitempty"`
	DelaySeconds        float64 `protobuf:"fixed64,13,opt,name=delaySeconds,proto3" json:"delaySeconds,omitempty"`
}

func NewPopulatedHealthCheck 

func NewPopulatedHealthCheck(r randyApplication, easy bool) *HealthCheck

func (*HealthCheck) Descriptor 

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

func (*HealthCheck) Equal 

func (this *HealthCheck) Equal(that interface{}) bool

func (*HealthCheck) GoString 

func (this *HealthCheck) GoString() string

func (*HealthCheck) Marshal 

func (m *HealthCheck) Marshal() (dAtA []byte, err error)

func (*HealthCheck) MarshalTo 

func (m *HealthCheck) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) Size 

func (m *HealthCheck) Size() (n int)

func (*HealthCheck) String 

func (m *HealthCheck) String() string

func (*HealthCheck) Unmarshal 

func (m *HealthCheck) Unmarshal(dAtA []byte) error

func (*HealthCheck) VerboseEqual 

func (this *HealthCheck) VerboseEqual(that interface{}) error

type InternalRaftRequest 

type InternalRaftRequest struct {
	ID     uint64         `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Action []*StoreAction `protobuf:"bytes,2,rep,name=action" json:"action,omitempty"`
}

Contains one of many protobuf encoded objects to replicate over the raft backend with a request ID to track when the action is effectively applied

func NewPopulatedInternalRaftRequest 

func NewPopulatedInternalRaftRequest(r randyRaft, easy bool) *InternalRaftRequest

func (*InternalRaftRequest) Descriptor 

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

func (*InternalRaftRequest) Equal 

func (this *InternalRaftRequest) Equal(that interface{}) bool

func (*InternalRaftRequest) GoString 

func (this *InternalRaftRequest) GoString() string

func (*InternalRaftRequest) Marshal 

func (m *InternalRaftRequest) Marshal() (dAtA []byte, err error)

func (*InternalRaftRequest) MarshalTo 

func (m *InternalRaftRequest) MarshalTo(dAtA []byte) (int, error)

func (*InternalRaftRequest) ProtoMessage 

func (*InternalRaftRequest) ProtoMessage()

func (*InternalRaftRequest) Reset 

func (m *InternalRaftRequest) Reset()

func (*InternalRaftRequest) Size 

func (m *InternalRaftRequest) Size() (n int)

func (*InternalRaftRequest) String 

func (m *InternalRaftRequest) String() string

func (*InternalRaftRequest) Unmarshal 

func (m *InternalRaftRequest) Unmarshal(dAtA []byte) error

func (*InternalRaftRequest) VerboseEqual 

func (this *InternalRaftRequest) VerboseEqual(that interface{}) error

type KillPolicy 

type KillPolicy struct {
	Duration int64 `protobuf:"varint,1,opt,name=duration,proto3" json:"duration,omitempty"`
}

func NewPopulatedKillPolicy 

func NewPopulatedKillPolicy(r randyApplication, easy bool) *KillPolicy

func (*KillPolicy) Descriptor 

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

func (*KillPolicy) Equal 

func (this *KillPolicy) Equal(that interface{}) bool

func (*KillPolicy) GoString 

func (this *KillPolicy) GoString() string

func (*KillPolicy) Marshal 

func (m *KillPolicy) Marshal() (dAtA []byte, err error)

func (*KillPolicy) MarshalTo 

func (m *KillPolicy) MarshalTo(dAtA []byte) (int, error)

func (*KillPolicy) ProtoMessage 

func (*KillPolicy) ProtoMessage()

func (*KillPolicy) Reset 

func (m *KillPolicy) Reset()

func (*KillPolicy) Size 

func (m *KillPolicy) Size() (n int)

func (*KillPolicy) String 

func (m *KillPolicy) String() string

func (*KillPolicy) Unmarshal 

func (m *KillPolicy) Unmarshal(dAtA []byte) error

func (*KillPolicy) VerboseEqual 

func (this *KillPolicy) VerboseEqual(that interface{}) error

type Node added in v0.1.3 

type Node struct {
	ID                string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	AdvertiseAddr     string            `protobuf:"bytes,2,opt,name=advertiseAddr,proto3" json:"advertiseAddr,omitempty"`
	ListenAddr        string            `protobuf:"bytes,3,opt,name=listenAddr,proto3" json:"listenAddr,omitempty"`
	RaftListenAddr    string            `protobuf:"bytes,4,opt,name=raftListenAddr,proto3" json:"raftListenAddr,omitempty"`
	RaftAdvertiseAddr string            `protobuf:"bytes,5,opt,name=raftAdvertiseAddr,proto3" json:"raftAdvertiseAddr,omitempty"`
	Status            string            `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	Labels            map[string]string `` /* 146-byte string literal not displayed */
	Role              string            `protobuf:"bytes,8,opt,name=role,proto3" json:"role,omitempty"`
	RaftID            uint64            `protobuf:"varint,9,opt,name=raftID,proto3" json:"raftID,omitempty"`
}

func NewPopulatedNode added in v0.1.3 

func NewPopulatedNode(r randyRaft, easy bool) *Node

func (*Node) Descriptor added in v0.1.3 

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

func (*Node) Equal added in v0.1.3 

func (this *Node) Equal(that interface{}) bool

func (*Node) GoString added in v0.1.3 

func (this *Node) GoString() string

func (*Node) Marshal added in v0.1.3 

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo added in v0.1.3 

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) ProtoMessage added in v0.1.3 

func (*Node) ProtoMessage()

func (*Node) Reset added in v0.1.3 

func (m *Node) Reset()

func (*Node) Size added in v0.1.3 

func (m *Node) Size() (n int)

func (*Node) String added in v0.1.3 

func (m *Node) String() string

func (*Node) Unmarshal added in v0.1.3 

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) VerboseEqual added in v0.1.3 

func (this *Node) VerboseEqual(that interface{}) error

type OfferAllocatorItem 

type OfferAllocatorItem struct {
	SlotID   string `protobuf:"bytes,1,opt,name=slotId,proto3" json:"slotId,omitempty"`
	OfferID  string `protobuf:"bytes,2,opt,name=offerId,proto3" json:"offerId,omitempty"`
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	AgentID  string `protobuf:"bytes,4,opt,name=agentId,proto3" json:"agentId,omitempty"`
}

func NewPopulatedOfferAllocatorItem 

func NewPopulatedOfferAllocatorItem(r randyApplication, easy bool) *OfferAllocatorItem

func (*OfferAllocatorItem) Descriptor 

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

func (*OfferAllocatorItem) Equal 

func (this *OfferAllocatorItem) Equal(that interface{}) bool

func (*OfferAllocatorItem) GoString 

func (this *OfferAllocatorItem) GoString() string

func (*OfferAllocatorItem) Marshal 

func (m *OfferAllocatorItem) Marshal() (dAtA []byte, err error)

func (*OfferAllocatorItem) MarshalTo 

func (m *OfferAllocatorItem) MarshalTo(dAtA []byte) (int, error)

func (*OfferAllocatorItem) ProtoMessage 

func (*OfferAllocatorItem) ProtoMessage()

func (*OfferAllocatorItem) Reset 

func (m *OfferAllocatorItem) Reset()

func (*OfferAllocatorItem) Size 

func (m *OfferAllocatorItem) Size() (n int)

func (*OfferAllocatorItem) String 

func (m *OfferAllocatorItem) String() string

func (*OfferAllocatorItem) Unmarshal 

func (m *OfferAllocatorItem) Unmarshal(dAtA []byte) error

func (*OfferAllocatorItem) VerboseEqual 

func (this *OfferAllocatorItem) VerboseEqual(that interface{}) error

type Parameter 

type Parameter struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func NewPopulatedParameter 

func NewPopulatedParameter(r randyApplication, easy bool) *Parameter

func (*Parameter) Descriptor 

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

func (*Parameter) Equal 

func (this *Parameter) Equal(that interface{}) bool

func (*Parameter) GoString 

func (this *Parameter) GoString() string

func (*Parameter) Marshal 

func (m *Parameter) Marshal() (dAtA []byte, err error)

func (*Parameter) MarshalTo 

func (m *Parameter) MarshalTo(dAtA []byte) (int, error)

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) Size 

func (m *Parameter) Size() (n int)

func (*Parameter) String 

func (m *Parameter) String() string

func (*Parameter) Unmarshal 

func (m *Parameter) Unmarshal(dAtA []byte) error

func (*Parameter) VerboseEqual 

func (this *Parameter) VerboseEqual(that interface{}) error

type PortMapping 

type PortMapping struct {
	ContainerPort int32  `protobuf:"varint,1,opt,name=containerPort,proto3" json:"containerPort,omitempty"`
	Name          string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Protocol      string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
}

func NewPopulatedPortMapping 

func NewPopulatedPortMapping(r randyApplication, easy bool) *PortMapping

func (*PortMapping) Descriptor 

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

func (*PortMapping) Equal 

func (this *PortMapping) Equal(that interface{}) bool

func (*PortMapping) GoString 

func (this *PortMapping) GoString() string

func (*PortMapping) Marshal 

func (m *PortMapping) Marshal() (dAtA []byte, err error)

func (*PortMapping) MarshalTo 

func (m *PortMapping) MarshalTo(dAtA []byte) (int, error)

func (*PortMapping) ProtoMessage 

func (*PortMapping) ProtoMessage()

func (*PortMapping) Reset 

func (m *PortMapping) Reset()

func (*PortMapping) Size 

func (m *PortMapping) Size() (n int)

func (*PortMapping) String 

func (m *PortMapping) String() string

func (*PortMapping) Unmarshal 

func (m *PortMapping) Unmarshal(dAtA []byte) error

func (*PortMapping) VerboseEqual 

func (this *PortMapping) VerboseEqual(that interface{}) error

type RestartPolicy 

type RestartPolicy struct {
}

func NewPopulatedRestartPolicy 

func NewPopulatedRestartPolicy(r randyApplication, easy bool) *RestartPolicy

func (*RestartPolicy) Descriptor 

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

func (*RestartPolicy) Equal 

func (this *RestartPolicy) Equal(that interface{}) bool

func (*RestartPolicy) GoString 

func (this *RestartPolicy) GoString() string

func (*RestartPolicy) Marshal 

func (m *RestartPolicy) Marshal() (dAtA []byte, err error)

func (*RestartPolicy) MarshalTo 

func (m *RestartPolicy) MarshalTo(dAtA []byte) (int, error)

func (*RestartPolicy) ProtoMessage 

func (*RestartPolicy) ProtoMessage()

func (*RestartPolicy) Reset 

func (m *RestartPolicy) Reset()

func (*RestartPolicy) Size 

func (m *RestartPolicy) Size() (n int)

func (*RestartPolicy) String 

func (m *RestartPolicy) String() string

func (*RestartPolicy) Unmarshal 

func (m *RestartPolicy) Unmarshal(dAtA []byte) error

func (*RestartPolicy) VerboseEqual 

func (this *RestartPolicy) VerboseEqual(that interface{}) error

type Slot 

type Slot struct {
	Index                int32          `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	ID                   string         `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	AppID                string         `protobuf:"bytes,3,opt,name=appId,proto3" json:"appId,omitempty"`
	VersionID            string         `protobuf:"bytes,4,opt,name=versionId,proto3" json:"versionId,omitempty"`
	State                string         `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	MarkForDeletion      bool           `protobuf:"varint,6,opt,name=markForDeletion,proto3" json:"markForDeletion,omitempty"`
	MarkForRollingUpdate bool           `protobuf:"varint,7,opt,name=markForRollingUpdate,proto3" json:"markForRollingUpdate,omitempty"`
	Healthy              bool           `protobuf:"varint,8,opt,name=healthy,proto3" json:"healthy,omitempty"`
	CurrentTask          *Task          `protobuf:"bytes,9,opt,name=CurrentTask" json:"CurrentTask,omitempty"`
	RestartPolicy        *RestartPolicy `protobuf:"bytes,10,opt,name=restartPolicy" json:"restartPolicy,omitempty"`
}

func NewPopulatedSlot 

func NewPopulatedSlot(r randyApplication, easy bool) *Slot

func (*Slot) Descriptor 

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

func (*Slot) Equal 

func (this *Slot) Equal(that interface{}) bool

func (*Slot) GoString 

func (this *Slot) GoString() string

func (*Slot) Marshal 

func (m *Slot) Marshal() (dAtA []byte, err error)

func (*Slot) MarshalTo 

func (m *Slot) MarshalTo(dAtA []byte) (int, error)

func (*Slot) ProtoMessage 

func (*Slot) ProtoMessage()

func (*Slot) Reset 

func (m *Slot) Reset()

func (*Slot) Size 

func (m *Slot) Size() (n int)

func (*Slot) String 

func (m *Slot) String() string

func (*Slot) Unmarshal 

func (m *Slot) Unmarshal(dAtA []byte) error

func (*Slot) VerboseEqual 

func (this *Slot) VerboseEqual(that interface{}) error

type State added in v0.1.9 

type State struct {
	Name                string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CurrentSlotIndex    int64  `protobuf:"varint,2,opt,name=currentSlotIndex,proto3" json:"currentSlotIndex,omitempty"`
	TargetSlotIndex     int64  `protobuf:"varint,3,opt,name=targetSlotIndex,proto3" json:"targetSlotIndex,omitempty"`
	SlotCountNeedUpdate int64  `protobuf:"varint,4,opt,name=slotCountNeedUpdate,proto3" json:"slotCountNeedUpdate,omitempty"`
}

func NewPopulatedState added in v0.1.9 

func NewPopulatedState(r randyApplication, easy bool) *State

func (*State) Descriptor added in v0.1.9 

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

func (*State) Equal added in v0.1.9 

func (this *State) Equal(that interface{}) bool

func (*State) GoString added in v0.1.9 

func (this *State) GoString() string

func (*State) Marshal added in v0.1.9 

func (m *State) Marshal() (dAtA []byte, err error)

func (*State) MarshalTo added in v0.1.9 

func (m *State) MarshalTo(dAtA []byte) (int, error)

func (*State) ProtoMessage added in v0.1.9 

func (*State) ProtoMessage()

func (*State) Reset added in v0.1.9 

func (m *State) Reset()

func (*State) Size added in v0.1.9 

func (m *State) Size() (n int)

func (*State) String added in v0.1.9 

func (m *State) String() string

func (*State) Unmarshal added in v0.1.9 

func (m *State) Unmarshal(dAtA []byte) error

func (*State) VerboseEqual added in v0.1.9 

func (this *State) VerboseEqual(that interface{}) error

type StateMachine added in v0.1.9 

type StateMachine struct {
	State *State `protobuf:"bytes,1,opt,name=state" json:"state,omitempty"`
}

func NewPopulatedStateMachine added in v0.1.9 

func NewPopulatedStateMachine(r randyApplication, easy bool) *StateMachine

func (*StateMachine) Descriptor added in v0.1.9 

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

func (*StateMachine) Equal added in v0.1.9 

func (this *StateMachine) Equal(that interface{}) bool

func (*StateMachine) GoString added in v0.1.9 

func (this *StateMachine) GoString() string

func (*StateMachine) Marshal added in v0.1.9 

func (m *StateMachine) Marshal() (dAtA []byte, err error)

func (*StateMachine) MarshalTo added in v0.1.9 

func (m *StateMachine) MarshalTo(dAtA []byte) (int, error)

func (*StateMachine) ProtoMessage added in v0.1.9 

func (*StateMachine) ProtoMessage()

func (*StateMachine) Reset added in v0.1.9 

func (m *StateMachine) Reset()

func (*StateMachine) Size added in v0.1.9 

func (m *StateMachine) Size() (n int)

func (*StateMachine) String added in v0.1.9 

func (m *StateMachine) String() string

func (*StateMachine) Unmarshal added in v0.1.9 

func (m *StateMachine) Unmarshal(dAtA []byte) error

func (*StateMachine) VerboseEqual added in v0.1.9 

func (this *StateMachine) VerboseEqual(that interface{}) error

type StoreAction 

type StoreAction struct {
	Action StoreActionKind `protobuf:"varint,1,opt,name=action,proto3,enum=types.StoreActionKind" json:"action,omitempty"`
	// Types that are valid to be assigned to Target:
	//	*StoreAction_Application
	//	*StoreAction_Framework
	//	*StoreAction_Version
	//	*StoreAction_Slot
	//	*StoreAction_Task
	//	*StoreAction_OfferAllocatorItem
	//	*StoreAction_Node
	Target isStoreAction_Target `protobuf_oneof:"target"`
}

StoreAction defines a target and operation to apply on the storage system.

func NewPopulatedStoreAction 

func NewPopulatedStoreAction(r randyRaft, easy bool) *StoreAction

func (*StoreAction) Descriptor 

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

func (*StoreAction) Equal 

func (this *StoreAction) Equal(that interface{}) bool

func (*StoreAction) GetApplication 

func (m *StoreAction) GetApplication() *Application

func (*StoreAction) GetFramework 

func (m *StoreAction) GetFramework() *Framework

func (*StoreAction) GetNode added in v0.1.3 

func (m *StoreAction) GetNode() *Node

func (*StoreAction) GetOfferAllocatorItem 

func (m *StoreAction) GetOfferAllocatorItem() *OfferAllocatorItem

func (*StoreAction) GetSlot 

func (m *StoreAction) GetSlot() *Slot

func (*StoreAction) GetTarget 

func (m *StoreAction) GetTarget() isStoreAction_Target

func (*StoreAction) GetTask 

func (m *StoreAction) GetTask() *Task

func (*StoreAction) GetVersion 

func (m *StoreAction) GetVersion() *Version

func (*StoreAction) GoString 

func (this *StoreAction) GoString() string

func (*StoreAction) Marshal 

func (m *StoreAction) Marshal() (dAtA []byte, err error)

func (*StoreAction) MarshalTo 

func (m *StoreAction) MarshalTo(dAtA []byte) (int, error)

func (*StoreAction) ProtoMessage 

func (*StoreAction) ProtoMessage()

func (*StoreAction) Reset 

func (m *StoreAction) Reset()

func (*StoreAction) Size 

func (m *StoreAction) Size() (n int)

func (*StoreAction) String 

func (m *StoreAction) String() string

func (*StoreAction) Unmarshal 

func (m *StoreAction) Unmarshal(dAtA []byte) error

func (*StoreAction) VerboseEqual 

func (this *StoreAction) VerboseEqual(that interface{}) error

func (*StoreAction) XXX_OneofFuncs 

func (*StoreAction) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type StoreActionKind 

type StoreActionKind int32

StoreActionKind defines the operation to take on the store for the target of a storage action. 

const (
	StoreActionKindUnknown StoreActionKind = 0
	StoreActionKindCreate  StoreActionKind = 1
	StoreActionKindUpdate  StoreActionKind = 2
	StoreActionKindRemove  StoreActionKind = 3
)

func (StoreActionKind) EnumDescriptor 

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

func (StoreActionKind) String 

func (x StoreActionKind) String() string

type StoreAction_Application 

type StoreAction_Application struct {
	Application *Application `protobuf:"bytes,2,opt,name=application,oneof"`
}

func NewPopulatedStoreAction_Application 

func NewPopulatedStoreAction_Application(r randyRaft, easy bool) *StoreAction_Application

func (*StoreAction_Application) Equal 

func (this *StoreAction_Application) Equal(that interface{}) bool

func (*StoreAction_Application) GoString 

func (this *StoreAction_Application) GoString() string

func (*StoreAction_Application) MarshalTo 

func (m *StoreAction_Application) MarshalTo(dAtA []byte) (int, error)

func (*StoreAction_Application) Size 

func (m *StoreAction_Application) Size() (n int)

func (*StoreAction_Application) VerboseEqual 

func (this *StoreAction_Application) VerboseEqual(that interface{}) error

type StoreAction_Framework 

type StoreAction_Framework struct {
	Framework *Framework `protobuf:"bytes,3,opt,name=framework,oneof"`
}

func NewPopulatedStoreAction_Framework 

func NewPopulatedStoreAction_Framework(r randyRaft, easy bool) *StoreAction_Framework

func (*StoreAction_Framework) Equal 

func (this *StoreAction_Framework) Equal(that interface{}) bool

func (*StoreAction_Framework) GoString 

func (this *StoreAction_Framework) GoString() string

func (*StoreAction_Framework) MarshalTo 

func (m *StoreAction_Framework) MarshalTo(dAtA []byte) (int, error)

func (*StoreAction_Framework) Size 

func (m *StoreAction_Framework) Size() (n int)

func (*StoreAction_Framework) VerboseEqual 

func (this *StoreAction_Framework) VerboseEqual(that interface{}) error

type StoreAction_Node added in v0.1.3 

type StoreAction_Node struct {
	Node *Node `protobuf:"bytes,8,opt,name=node,oneof"`
}

func NewPopulatedStoreAction_Node added in v0.1.3 

func NewPopulatedStoreAction_Node(r randyRaft, easy bool) *StoreAction_Node

func (*StoreAction_Node) Equal added in v0.1.3 

func (this *StoreAction_Node) Equal(that interface{}) bool

func (*StoreAction_Node) GoString added in v0.1.3 

func (this *StoreAction_Node) GoString() string

func (*StoreAction_Node) MarshalTo added in v0.1.3 

func (m *StoreAction_Node) MarshalTo(dAtA []byte) (int, error)

func (*StoreAction_Node) Size added in v0.1.3 

func (m *StoreAction_Node) Size() (n int)

func (*StoreAction_Node) VerboseEqual added in v0.1.3 

func (this *StoreAction_Node) VerboseEqual(that interface{}) error

type StoreAction_OfferAllocatorItem 

type StoreAction_OfferAllocatorItem struct {
	OfferAllocatorItem *OfferAllocatorItem `protobuf:"bytes,7,opt,name=offerAllocatorItem,oneof"`
}

func NewPopulatedStoreAction_OfferAllocatorItem 

func NewPopulatedStoreAction_OfferAllocatorItem(r randyRaft, easy bool) *StoreAction_OfferAllocatorItem

func (*StoreAction_OfferAllocatorItem) Equal 

func (this *StoreAction_OfferAllocatorItem) Equal(that interface{}) bool

func (*StoreAction_OfferAllocatorItem) GoString 

func (this *StoreAction_OfferAllocatorItem) GoString() string

func (*StoreAction_OfferAllocatorItem) MarshalTo 

func (m *StoreAction_OfferAllocatorItem) MarshalTo(dAtA []byte) (int, error)

func (*StoreAction_OfferAllocatorItem) Size 

func (m *StoreAction_OfferAllocatorItem) Size() (n int)

func (*StoreAction_OfferAllocatorItem) VerboseEqual 

func (this *StoreAction_OfferAllocatorItem) VerboseEqual(that interface{}) error

type StoreAction_Slot 

type StoreAction_Slot struct {
	Slot *Slot `protobuf:"bytes,5,opt,name=slot,oneof"`
}

func NewPopulatedStoreAction_Slot 

func NewPopulatedStoreAction_Slot(r randyRaft, easy bool) *StoreAction_Slot

func (*StoreAction_Slot) Equal 

func (this *StoreAction_Slot) Equal(that interface{}) bool

func (*StoreAction_Slot) GoString 

func (this *StoreAction_Slot) GoString() string

func (*StoreAction_Slot) MarshalTo 

func (m *StoreAction_Slot) MarshalTo(dAtA []byte) (int, error)

func (*StoreAction_Slot) Size 

func (m *StoreAction_Slot) Size() (n int)

func (*StoreAction_Slot) VerboseEqual 

func (this *StoreAction_Slot) VerboseEqual(that interface{}) error

type StoreAction_Task 

type StoreAction_Task struct {
	Task *Task `protobuf:"bytes,6,opt,name=task,oneof"`
}

func NewPopulatedStoreAction_Task 

func NewPopulatedStoreAction_Task(r randyRaft, easy bool) *StoreAction_Task

func (*StoreAction_Task) Equal 

func (this *StoreAction_Task) Equal(that interface{}) bool

func (*StoreAction_Task) GoString 

func (this *StoreAction_Task) GoString() string

func (*StoreAction_Task) MarshalTo 

func (m *StoreAction_Task) MarshalTo(dAtA []byte) (int, error)

func (*StoreAction_Task) Size 

func (m *StoreAction_Task) Size() (n int)

func (*StoreAction_Task) VerboseEqual 

func (this *StoreAction_Task) VerboseEqual(that interface{}) error

type StoreAction_Version 

type StoreAction_Version struct {
	Version *Version `protobuf:"bytes,4,opt,name=version,oneof"`
}

func NewPopulatedStoreAction_Version 

func NewPopulatedStoreAction_Version(r randyRaft, easy bool) *StoreAction_Version

func (*StoreAction_Version) Equal 

func (this *StoreAction_Version) Equal(that interface{}) bool

func (*StoreAction_Version) GoString 

func (this *StoreAction_Version) GoString() string

func (*StoreAction_Version) MarshalTo 

func (m *StoreAction_Version) MarshalTo(dAtA []byte) (int, error)

func (*StoreAction_Version) Size 

func (m *StoreAction_Version) Size() (n int)

func (*StoreAction_Version) VerboseEqual 

func (this *StoreAction_Version) VerboseEqual(that interface{}) error

type Task 

type Task struct {
	ID            string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	AppID         string   `protobuf:"bytes,2,opt,name=appId,proto3" json:"appId,omitempty"`
	VersionID     string   `protobuf:"bytes,3,opt,name=versionId,proto3" json:"versionId,omitempty"`
	SlotID        string   `protobuf:"bytes,4,opt,name=slotId,proto3" json:"slotId,omitempty"`
	State         string   `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	Stdout        string   `protobuf:"bytes,6,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr        string   `protobuf:"bytes,7,opt,name=stderr,proto3" json:"stderr,omitempty"`
	HostPorts     []uint64 `protobuf:"varint,8,rep,packed,name=hostPorts" json:"hostPorts,omitempty"`
	OfferID       string   `protobuf:"bytes,9,opt,name=offerId,proto3" json:"offerId,omitempty"`
	AgentID       string   `protobuf:"bytes,10,opt,name=agentId,proto3" json:"agentId,omitempty"`
	Ip            string   `protobuf:"bytes,11,opt,name=ip,proto3" json:"ip,omitempty"`
	AgentHostName string   `protobuf:"bytes,12,opt,name=agentHostName,proto3" json:"agentHostName,omitempty"`
	Reason        string   `protobuf:"bytes,13,opt,name=reason,proto3" json:"reason,omitempty"`
	Message       string   `protobuf:"bytes,14,opt,name=message,proto3" json:"message,omitempty"`
	CreatedAt     int64    `protobuf:"varint,15,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	ArchivedAt    int64    `protobuf:"varint,16,opt,name=archivedAt,proto3" json:"archivedAt,omitempty"`
}

func NewPopulatedTask 

func NewPopulatedTask(r randyApplication, easy bool) *Task

func (*Task) Descriptor 

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

func (*Task) Equal 

func (this *Task) Equal(that interface{}) bool

func (*Task) GoString 

func (this *Task) GoString() string

func (*Task) Marshal 

func (m *Task) Marshal() (dAtA []byte, err error)

func (*Task) MarshalTo 

func (m *Task) MarshalTo(dAtA []byte) (int, error)

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) Size 

func (m *Task) Size() (n int)

func (*Task) String 

func (m *Task) String() string

func (*Task) Unmarshal 

func (m *Task) Unmarshal(dAtA []byte) error

func (*Task) VerboseEqual 

func (this *Task) VerboseEqual(that interface{}) error

type UpdatePolicy 

type UpdatePolicy struct {
	UpdateDelay  int32  `protobuf:"varint,1,opt,name=updateDelay,proto3" json:"updateDelay,omitempty"`
	MaxRetries   int32  `protobuf:"varint,2,opt,name=maxRetries,proto3" json:"maxRetries,omitempty"`
	MaxFailovers int32  `protobuf:"varint,3,opt,name=maxFailovers,proto3" json:"maxFailovers,omitempty"`
	Action       string `protobuf:"bytes,4,opt,name=action,proto3" json:"action,omitempty"`
}

func NewPopulatedUpdatePolicy 

func NewPopulatedUpdatePolicy(r randyApplication, easy bool) *UpdatePolicy

func (*UpdatePolicy) Descriptor 

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

func (*UpdatePolicy) Equal 

func (this *UpdatePolicy) Equal(that interface{}) bool

func (*UpdatePolicy) GoString 

func (this *UpdatePolicy) GoString() string

func (*UpdatePolicy) Marshal 

func (m *UpdatePolicy) Marshal() (dAtA []byte, err error)

func (*UpdatePolicy) MarshalTo 

func (m *UpdatePolicy) MarshalTo(dAtA []byte) (int, error)

func (*UpdatePolicy) ProtoMessage 

func (*UpdatePolicy) ProtoMessage()

func (*UpdatePolicy) Reset 

func (m *UpdatePolicy) Reset()

func (*UpdatePolicy) Size 

func (m *UpdatePolicy) Size() (n int)

func (*UpdatePolicy) String 

func (m *UpdatePolicy) String() string

func (*UpdatePolicy) Unmarshal 

func (m *UpdatePolicy) Unmarshal(dAtA []byte) error

func (*UpdatePolicy) VerboseEqual 

func (this *UpdatePolicy) VerboseEqual(that interface{}) error

type Version 

type Version struct {
	ID                string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PerviousVersionID string            `protobuf:"bytes,2,opt,name=perviousVersionID,proto3" json:"perviousVersionID,omitempty"`
	Command           string            `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"`
	Cpus              float64           `protobuf:"fixed64,4,opt,name=cpus,proto3" json:"cpus,omitempty"`
	Mem               float64           `protobuf:"fixed64,5,opt,name=mem,proto3" json:"mem,omitempty"`
	Disk              float64           `protobuf:"fixed64,6,opt,name=disk,proto3" json:"disk,omitempty"`
	Instances         int32             `protobuf:"varint,7,opt,name=instances,proto3" json:"instances,omitempty"`
	RunAs             string            `protobuf:"bytes,8,opt,name=runAs,proto3" json:"runAs,omitempty"`
	Container         *Container        `protobuf:"bytes,9,opt,name=container" json:"container,omitempty"`
	Labels            map[string]string `` /* 147-byte string literal not displayed */
	HealthCheck       *HealthCheck      `protobuf:"bytes,11,opt,name=healthCheck" json:"healthCheck,omitempty"`
	Env               map[string]string `` /* 141-byte string literal not displayed */
	KillPolicy        *KillPolicy       `protobuf:"bytes,13,opt,name=killPolicy" json:"killPolicy,omitempty"`
	UpdatePolicy      *UpdatePolicy     `protobuf:"bytes,14,opt,name=updatePolicy" json:"updatePolicy,omitempty"`
	Constraints       string            `protobuf:"bytes,15,opt,name=constraints,proto3" json:"constraints,omitempty"`
	Uris              []string          `protobuf:"bytes,16,rep,name=uris" json:"uris,omitempty"`
	Ip                []string          `protobuf:"bytes,17,rep,name=ip" json:"ip,omitempty"`
	Mode              string            `protobuf:"bytes,18,opt,name=mode,proto3" json:"mode,omitempty"`
	AppName           string            `protobuf:"bytes,19,opt,name=appName,proto3" json:"appName,omitempty"`
	AppID             string            `protobuf:"bytes,20,opt,name=appID,proto3" json:"appID,omitempty"`
	Priority          int32             `protobuf:"varint,21,opt,name=priority,proto3" json:"priority,omitempty"`
	Args              []string          `protobuf:"bytes,22,rep,name=args" json:"args,omitempty"`
}

func NewPopulatedVersion 

func NewPopulatedVersion(r randyApplication, easy bool) *Version

func (*Version) Descriptor 

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

func (*Version) Equal 

func (this *Version) Equal(that interface{}) bool

func (*Version) GoString 

func (this *Version) GoString() string

func (*Version) Marshal 

func (m *Version) Marshal() (dAtA []byte, err error)

func (*Version) MarshalTo 

func (m *Version) MarshalTo(dAtA []byte) (int, error)

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) Reset 

func (m *Version) Reset()

func (*Version) Size 

func (m *Version) Size() (n int)

func (*Version) String 

func (m *Version) String() string

func (*Version) Unmarshal 

func (m *Version) Unmarshal(dAtA []byte) error

func (*Version) VerboseEqual 

func (this *Version) VerboseEqual(that interface{}) error

type Volume 

type Volume struct {
	ContainerPath string `protobuf:"bytes,1,opt,name=containerPath,proto3" json:"containerPath,omitempty"`
	HostPath      string `protobuf:"bytes,2,opt,name=hostPath,proto3" json:"hostPath,omitempty"`
	Mode          string `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
}

func NewPopulatedVolume 

func NewPopulatedVolume(r randyApplication, easy bool) *Volume

func (*Volume) Descriptor 

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

func (*Volume) Equal 

func (this *Volume) Equal(that interface{}) bool

func (*Volume) GoString 

func (this *Volume) GoString() string

func (*Volume) Marshal 

func (m *Volume) Marshal() (dAtA []byte, err error)

func (*Volume) MarshalTo 

func (m *Volume) MarshalTo(dAtA []byte) (int, error)

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) Reset 

func (m *Volume) Reset()

func (*Volume) Size 

func (m *Volume) Size() (n int)

func (*Volume) String 

func (m *Volume) String() string

func (*Volume) Unmarshal 

func (m *Volume) Unmarshal(dAtA []byte) error

func (*Volume) VerboseEqual 

func (this *Volume) VerboseEqual(that interface{}) 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.