types

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2017 License: Apache-2.0 Imports: 9 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
Command
Slot
RestartPolicy
Task
OfferAllocatorItem
InternalRaftRequest
StoreAction
Framework
Agent

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 Agent 

type Agent struct {
	ID         string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RemoteAddr string            `protobuf:"bytes,2,opt,name=remoteAddr,proto3" json:"remoteAddr,omitempty"`
	Status     string            `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Labels     map[string]string `` /* 146-byte string literal not displayed */
}

func NewPopulatedAgent 

func NewPopulatedAgent(r randyRaft, easy bool) *Agent

func (*Agent) Descriptor 

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

func (*Agent) Equal 

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

func (*Agent) GoString 

func (this *Agent) GoString() string

func (*Agent) Marshal 

func (m *Agent) Marshal() (data []byte, err error)

func (*Agent) MarshalTo 

func (m *Agent) MarshalTo(data []byte) (int, error)

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) Reset 

func (m *Agent) Reset()

func (*Agent) Size 

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

func (*Agent) String 

func (m *Agent) String() string

func (*Agent) Unmarshal 

func (m *Agent) Unmarshal(data []byte) error

func (*Agent) VerboseEqual 

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

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"`
	State           string   `protobuf:"bytes,6,opt,name=state,proto3" json:"state,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"`
}

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 Command 

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

func NewPopulatedCommand 

func NewPopulatedCommand(r randyApplication, easy bool) *Command

func (*Command) Descriptor 

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

func (*Command) Equal 

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

func (*Command) GoString 

func (this *Command) GoString() string

func (*Command) Marshal 

func (m *Command) Marshal() (data []byte, err error)

func (*Command) MarshalTo 

func (m *Command) MarshalTo(data []byte) (int, error)

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) Size 

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

func (*Command) String 

func (m *Command) String() string

func (*Command) Unmarshal 

func (m *Command) Unmarshal(data []byte) error

func (*Command) VerboseEqual 

func (this *Command) 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"`
	Command             *Command `protobuf:"bytes,7,opt,name=command" json:"command,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"`
}

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 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"`
}

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" 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 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_Agent
	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) GetAgent 

func (m *StoreAction) GetAgent() *Agent

func (*StoreAction) GetApplication 

func (m *StoreAction) GetApplication() *Application

func (*StoreAction) GetFramework 

func (m *StoreAction) GetFramework() *Framework

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_Agent 

type StoreAction_Agent struct {
	Agent *Agent `protobuf:"bytes,8,opt,name=agent,oneof"`
}

func NewPopulatedStoreAction_Agent 

func NewPopulatedStoreAction_Agent(r randyRaft, easy bool) *StoreAction_Agent

func (*StoreAction_Agent) Equal 

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

func (*StoreAction_Agent) GoString 

func (this *StoreAction_Agent) GoString() string

func (*StoreAction_Agent) MarshalTo 

func (m *StoreAction_Agent) MarshalTo(data []byte) (int, error)

func (*StoreAction_Agent) Size 

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

func (*StoreAction_Agent) VerboseEqual 

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

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_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"`
	TaskInfoID    string   `protobuf:"bytes,2,opt,name=taskInfoId,proto3" json:"taskInfoId,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"`
	SlotID        string   `protobuf:"bytes,5,opt,name=slotId,proto3" json:"slotId,omitempty"`
	State         string   `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
	Stdout        string   `protobuf:"bytes,7,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr        string   `protobuf:"bytes,8,opt,name=stderr,proto3" json:"stderr,omitempty"`
	HostPorts     []uint64 `protobuf:"varint,9,rep,name=hostPorts" json:"hostPorts,omitempty"`
	OfferID       string   `protobuf:"bytes,10,opt,name=offerId,proto3" json:"offerId,omitempty"`
	AgentID       string   `protobuf:"bytes,11,opt,name=agentId,proto3" json:"agentId,omitempty"`
	Ip            string   `protobuf:"bytes,12,opt,name=ip,proto3" json:"ip,omitempty"`
	AgentHostName string   `protobuf:"bytes,13,opt,name=agentHostName,proto3" json:"agentHostName,omitempty"`
	Reason        string   `protobuf:"bytes,14,opt,name=reason,proto3" json:"reason,omitempty"`
	CreatedAt     int64    `protobuf:"varint,15,opt,name=createdAt,proto3" json:"createdAt,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 */
	HealthChecks      []*HealthCheck    `protobuf:"bytes,11,rep,name=healthChecks" json:"healthChecks,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,rep,name=constraints" 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"`
	AppID             string            `protobuf:"bytes,19,opt,name=appId,proto3" json:"appId,omitempty"`
	Priority          int32             `protobuf:"varint,20,opt,name=priority,proto3" json:"priority,omitempty"`
	Args              []string          `protobuf:"bytes,21,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.