proto

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Jul 30, 2021 License: MPL-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EvaluationTypeCluster  = "cluster"
	EvaluationTypeResource = "resource"
)
View Source 
const (
	DeploymentDone      = "done"
	DeploymentRunning   = "running"
	DeploymentCompleted = "completed"
	DeploymentFailed    = "failed"
)
View Source 
const (
	InstanceDesiredRunning = "running"
	InstanceDesiredStopped = "stopped"
)
View Source 
const (
	PlanStatusDone = "done"
)

Variables

View Source 
var (
	Component_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "PENDING",
		2: "QUEUED",
		3: "FAILED",
		4: "APPLIED",
		5: "CANCELED",
		6: "BLOCKED",
	}
	Component_Status_value = map[string]int32{
		"UNKNOWN":  0,
		"PENDING":  1,
		"QUEUED":   2,
		"FAILED":   3,
		"APPLIED":  4,
		"CANCELED": 5,
		"BLOCKED":  6,
	}
)

Enum value maps for Component_Status.

View Source 
var (
	Component_Action_name = map[int32]string{
		0: "CREATE",
		1: "DELETE",
	}
	Component_Action_value = map[string]int32{
		"CREATE": 0,
		"DELETE": 1,
	}
)

Enum value maps for Component_Action.

View Source 
var (
	Instance_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "PENDING",
		2: "RUNNING",
		3: "TAINTED",
		4: "STOPPED",
		5: "OUT",
	}
	Instance_Status_value = map[string]int32{
		"UNKNOWN": 0,
		"PENDING": 1,
		"RUNNING": 2,
		"TAINTED": 3,
		"STOPPED": 4,
		"OUT":     5,
	}
)

Enum value maps for Instance_Status.

View Source 
var (
	Instance_DesiredStatus_name = map[int32]string{
		0: "RUN",
		1: "STOP",
	}
	Instance_DesiredStatus_value = map[string]int32{
		"RUN":  0,
		"STOP": 1,
	}
)

Enum value maps for Instance_DesiredStatus.

View Source 
var (
	Evaluation_Status_name = map[int32]string{
		0: "PENDING",
		1: "COMPLETE",
		2: "FAILED",
		3: "CANCELLED",
	}
	Evaluation_Status_value = map[string]int32{
		"PENDING":   0,
		"COMPLETE":  1,
		"FAILED":    2,
		"CANCELLED": 3,
	}
)

Enum value maps for Evaluation_Status.

View Source 
var (
	Evaluation_Trigger_name = map[int32]string{
		0: "UNKNOWN",
		1: "SPECCHANGE",
		2: "NODECHANGE",
	}
	Evaluation_Trigger_value = map[string]int32{
		"UNKNOWN":    0,
		"SPECCHANGE": 1,
		"NODECHANGE": 2,
	}
)

Enum value maps for Evaluation_Trigger.

View Source 
var EnsembleService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.EnsembleService",
	HandlerType: (*EnsembleServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Apply",
			Handler:    _EnsembleService_Apply_Handler,
		},
		{
			MethodName: "ListDeployments",
			Handler:    _EnsembleService_ListDeployments_Handler,
		},
		{
			MethodName: "GetDeployment",
			Handler:    _EnsembleService_GetDeployment_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "operator/proto/structs.proto",
}

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

View Source 
var File_operator_proto_structs_proto protoreflect.FileDescriptor

Functions

func ClusterIDFromComponent added in v0.1.3 

func ClusterIDFromComponent(c *Component) (string, error)

func Cmp added in v0.1.3 

func Cmp(a, b *any.Any) (bool, error)

func Equal added in v0.1.1 

func Equal(p0, p1 proto.Message) bool

func MarshalAny added in v0.1.1 

func MarshalAny(m proto.Message) (*any.Any, error)

func MustMarshalAny added in v0.1.1 

func MustMarshalAny(m proto.Message) *any.Any

func MustUnmarshalAny added in v0.1.3 

func MustUnmarshalAny(a *any.Any) proto.Message

func ParseIndex added in v0.1.3 

func ParseIndex(n string) (uint64, error)

func RegisterEnsembleServiceServer added in v0.1.1 

func RegisterEnsembleServiceServer(s grpc.ServiceRegistrar, srv EnsembleServiceServer)

func UnmarshalAny added in v0.1.3 

func UnmarshalAny(a *any.Any) (proto.Message, error)

Types

type ClusterRef added in v0.1.3 

type ClusterRef interface {
	GetCluster() string
}

type ClusterSpec added in v0.1.1 

type ClusterSpec struct {

	// name of the backend
	Backend string `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	// version of the backend (RESERVED)
	Version   string               `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Groups    []*ClusterSpec_Group `protobuf:"bytes,4,rep,name=groups,proto3" json:"groups,omitempty"`
	Sequence  int64                `protobuf:"varint,5,opt,name=sequence,proto3" json:"sequence,omitempty"`
	DependsOn []string             `protobuf:"bytes,6,rep,name=dependsOn,proto3" json:"dependsOn,omitempty"`
	// contains filtered or unexported fields
}

Description of the cluster

func (*ClusterSpec) Copy added in v0.1.3 

func (c *ClusterSpec) Copy() *ClusterSpec

func (*ClusterSpec) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use ClusterSpec.ProtoReflect.Descriptor instead.

func (*ClusterSpec) GetBackend added in v0.1.1 

func (x *ClusterSpec) GetBackend() string

func (*ClusterSpec) GetCluster added in v0.1.3 

func (c *ClusterSpec) GetCluster() string

func (*ClusterSpec) GetDependsOn added in v0.1.3 

func (x *ClusterSpec) GetDependsOn() []string

func (*ClusterSpec) GetGroups added in v0.1.3 

func (x *ClusterSpec) GetGroups() []*ClusterSpec_Group

func (*ClusterSpec) GetSequence added in v0.1.3 

func (x *ClusterSpec) GetSequence() int64

func (*ClusterSpec) GetVersion added in v0.1.1 

func (x *ClusterSpec) GetVersion() string

func (*ClusterSpec) ProtoMessage added in v0.1.1 

func (*ClusterSpec) ProtoMessage()

func (*ClusterSpec) ProtoReflect added in v0.1.1 

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

func (*ClusterSpec) Reset added in v0.1.1 

func (x *ClusterSpec) Reset()

func (*ClusterSpec) String added in v0.1.1 

func (x *ClusterSpec) String() string

type ClusterSpec_Group added in v0.1.3 

type ClusterSpec_Group struct {
	Count     int64  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Type      string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Params    *Spec  `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`
	Resources *Spec  `protobuf:"bytes,5,opt,name=resources,proto3" json:"resources,omitempty"`
	Storage   *Spec  `protobuf:"bytes,6,opt,name=storage,proto3" json:"storage,omitempty"`
	Version   string `protobuf:"bytes,7,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterSpec_Group) Copy added in v0.1.3 

func (c *ClusterSpec_Group) Copy() *ClusterSpec_Group

func (*ClusterSpec_Group) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use ClusterSpec_Group.ProtoReflect.Descriptor instead.

func (*ClusterSpec_Group) GetCount added in v0.1.3 

func (x *ClusterSpec_Group) GetCount() int64

func (*ClusterSpec_Group) GetParams added in v0.1.3 

func (x *ClusterSpec_Group) GetParams() *Spec

func (*ClusterSpec_Group) GetResources added in v0.1.3 

func (x *ClusterSpec_Group) GetResources() *Spec

func (*ClusterSpec_Group) GetStorage added in v0.1.3 

func (x *ClusterSpec_Group) GetStorage() *Spec

func (*ClusterSpec_Group) GetType added in v0.1.3 

func (x *ClusterSpec_Group) GetType() string

func (*ClusterSpec_Group) GetVersion added in v0.1.3 

func (x *ClusterSpec_Group) GetVersion() string

func (*ClusterSpec_Group) ProtoMessage added in v0.1.3 

func (*ClusterSpec_Group) ProtoMessage()

func (*ClusterSpec_Group) ProtoReflect added in v0.1.3 

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

func (*ClusterSpec_Group) Reset added in v0.1.3 

func (x *ClusterSpec_Group) Reset()

func (*ClusterSpec_Group) String added in v0.1.3 

func (x *ClusterSpec_Group) String() string

type Component added in v0.1.1 

type Component struct {

	// id of the component
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// name is the name of the component
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// spec of the stuff being applied
	Spec *any.Any `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// generation of the component
	Sequence int64 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// status of the component
	Status Component_Status `protobuf:"varint,5,opt,name=status,proto3,enum=proto.Component_Status" json:"status,omitempty"`
	// Type of action
	Action Component_Action `protobuf:"varint,6,opt,name=action,proto3,enum=proto.Component_Action" json:"action,omitempty"`
	// timestamp
	Timestamp *timestamp.Timestamp `protobuf:"bytes,7,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	// metadata of the component
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	PrevId   string            `protobuf:"bytes,9,opt,name=prevId,proto3" json:"prevId,omitempty"`
	// contains filtered or unexported fields
}

Component is like a snapshot or something. AKA Evaluation

func (*Component) Copy added in v0.1.3 

func (c *Component) Copy() *Component

func (*Component) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use Component.ProtoReflect.Descriptor instead.

func (*Component) GetAction added in v0.1.1 

func (x *Component) GetAction() Component_Action

func (*Component) GetId added in v0.1.1 

func (x *Component) GetId() string

func (*Component) GetMetadata added in v0.1.1 

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

func (*Component) GetName added in v0.1.1 

func (x *Component) GetName() string

func (*Component) GetPrevId added in v0.1.3 

func (x *Component) GetPrevId() string

func (*Component) GetSequence added in v0.1.1 

func (x *Component) GetSequence() int64

func (*Component) GetSpec added in v0.1.1 

func (x *Component) GetSpec() *any.Any

func (*Component) GetStatus added in v0.1.1 

func (x *Component) GetStatus() Component_Status

func (*Component) GetTimestamp added in v0.1.1 

func (x *Component) GetTimestamp() *timestamp.Timestamp

func (*Component) IsDone added in v0.1.3 

func (c *Component) IsDone() bool

func (*Component) ProtoMessage added in v0.1.1 

func (*Component) ProtoMessage()

func (*Component) ProtoReflect added in v0.1.1 

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

func (*Component) Reset added in v0.1.1 

func (x *Component) Reset()

func (*Component) String added in v0.1.1 

func (x *Component) String() string

func (*Component) Type added in v0.1.3 

func (c *Component) Type() string

type Component_Action added in v0.1.1 

type Component_Action int32
const (
	Component_CREATE Component_Action = 0
	Component_DELETE Component_Action = 1
)

func (Component_Action) Descriptor added in v0.1.1 

func (Component_Action) Descriptor() protoreflect.EnumDescriptor

func (Component_Action) Enum added in v0.1.1 

func (x Component_Action) Enum() *Component_Action

func (Component_Action) EnumDescriptor deprecated added in v0.1.1 

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

Deprecated: Use Component_Action.Descriptor instead.

func (Component_Action) Number added in v0.1.1 

func (x Component_Action) Number() protoreflect.EnumNumber

func (Component_Action) String added in v0.1.1 

func (x Component_Action) String() string

func (Component_Action) Type added in v0.1.1 

func (Component_Action) Type() protoreflect.EnumType

type Component_Status added in v0.1.1 

type Component_Status int32
const (
	Component_UNKNOWN  Component_Status = 0
	Component_PENDING  Component_Status = 1
	Component_QUEUED   Component_Status = 2
	Component_FAILED   Component_Status = 3
	Component_APPLIED  Component_Status = 4
	Component_CANCELED Component_Status = 5
	Component_BLOCKED  Component_Status = 6 // Before pending
)

func (Component_Status) Descriptor added in v0.1.1 

func (Component_Status) Descriptor() protoreflect.EnumDescriptor

func (Component_Status) Enum added in v0.1.1 

func (x Component_Status) Enum() *Component_Status

func (Component_Status) EnumDescriptor deprecated added in v0.1.1 

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

Deprecated: Use Component_Status.Descriptor instead.

func (Component_Status) Number added in v0.1.1 

func (x Component_Status) Number() protoreflect.EnumNumber

func (Component_Status) String added in v0.1.1 

func (x Component_Status) String() string

func (Component_Status) Type added in v0.1.1 

func (Component_Status) Type() protoreflect.EnumType

type Deployment added in v0.1.3 

type Deployment struct {
	Name      string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Instances []*Instance `protobuf:"bytes,2,rep,name=instances,proto3" json:"instances,omitempty"`
	Status    string      `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// sequence applied for this deployment
	Sequence  int64  `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Backend   string `protobuf:"bytes,5,opt,name=backend,proto3" json:"backend,omitempty"`
	CompId    string `protobuf:"bytes,6,opt,name=compId,proto3" json:"compId,omitempty"`
	DnsSuffix string `protobuf:"bytes,7,opt,name=dnsSuffix,proto3" json:"dnsSuffix,omitempty"`
	Id        string `protobuf:"bytes,8,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Deployment describes the current state of the cluster

func (*Deployment) Copy added in v0.1.3 

func (d *Deployment) Copy() *Deployment

func (*Deployment) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use Deployment.ProtoReflect.Descriptor instead.

func (*Deployment) Filter added in v0.1.3 

func (d *Deployment) Filter(filter func(n *Instance) bool) (res []*Instance)

func (*Deployment) GetBackend added in v0.1.3 

func (x *Deployment) GetBackend() string

func (*Deployment) GetCompId added in v0.1.3 

func (x *Deployment) GetCompId() string

func (*Deployment) GetDnsSuffix added in v0.1.3 

func (x *Deployment) GetDnsSuffix() string

func (*Deployment) GetId added in v0.1.3 

func (x *Deployment) GetId() string

func (*Deployment) GetInstances added in v0.1.3 

func (x *Deployment) GetInstances() []*Instance

func (*Deployment) GetName added in v0.1.3 

func (x *Deployment) GetName() string

func (*Deployment) GetSequence added in v0.1.3 

func (x *Deployment) GetSequence() int64

func (*Deployment) GetStatus added in v0.1.3 

func (x *Deployment) GetStatus() string

func (*Deployment) ProtoMessage added in v0.1.3 

func (*Deployment) ProtoMessage()

func (*Deployment) ProtoReflect added in v0.1.3 

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

func (*Deployment) Reset added in v0.1.3 

func (x *Deployment) Reset()

func (*Deployment) String added in v0.1.3 

func (x *Deployment) String() string

type EnsembleServiceClient added in v0.1.1 

type EnsembleServiceClient interface {
	Apply(ctx context.Context, in *Component, opts ...grpc.CallOption) (*Component, error)
	ListDeployments(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListDeploymentsResp, error)
	GetDeployment(ctx context.Context, in *GetDeploymentReq, opts ...grpc.CallOption) (*Deployment, error)
}

EnsembleServiceClient is the client API for EnsembleService service.

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

func NewEnsembleServiceClient added in v0.1.1 

func NewEnsembleServiceClient(cc grpc.ClientConnInterface) EnsembleServiceClient

type EnsembleServiceServer added in v0.1.1 

type EnsembleServiceServer interface {
	Apply(context.Context, *Component) (*Component, error)
	ListDeployments(context.Context, *empty.Empty) (*ListDeploymentsResp, error)
	GetDeployment(context.Context, *GetDeploymentReq) (*Deployment, error)
	// contains filtered or unexported methods
}

EnsembleServiceServer is the server API for EnsembleService service. All implementations must embed UnimplementedEnsembleServiceServer for forward compatibility

type Evaluation 

type Evaluation struct {

	// id of the evaluation
	Id           string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status       Evaluation_Status  `protobuf:"varint,2,opt,name=status,proto3,enum=proto.Evaluation_Status" json:"status,omitempty"`
	TriggeredBy  Evaluation_Trigger `protobuf:"varint,3,opt,name=triggeredBy,proto3,enum=proto.Evaluation_Trigger" json:"triggeredBy,omitempty"`
	DeploymentID string             `protobuf:"bytes,4,opt,name=deploymentID,proto3" json:"deploymentID,omitempty"`
	Type         string             `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	Sequence     int64              `protobuf:"varint,6,opt,name=sequence,proto3" json:"sequence,omitempty"`
	ComponentID  string             `protobuf:"bytes,7,opt,name=componentID,proto3" json:"componentID,omitempty"`
	// contains filtered or unexported fields
}

func (*Evaluation) Descriptor deprecated 

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

Deprecated: Use Evaluation.ProtoReflect.Descriptor instead.

func (*Evaluation) GetComponentID added in v0.1.3 

func (x *Evaluation) GetComponentID() string

func (*Evaluation) GetDeploymentID added in v0.1.3 

func (x *Evaluation) GetDeploymentID() string

func (*Evaluation) GetId added in v0.1.3 

func (x *Evaluation) GetId() string

func (*Evaluation) GetSequence added in v0.1.3 

func (x *Evaluation) GetSequence() int64

func (*Evaluation) GetStatus 

func (x *Evaluation) GetStatus() Evaluation_Status

func (*Evaluation) GetTriggeredBy added in v0.1.3 

func (x *Evaluation) GetTriggeredBy() Evaluation_Trigger

func (*Evaluation) GetType added in v0.1.3 

func (x *Evaluation) GetType() string

func (*Evaluation) ProtoMessage 

func (*Evaluation) ProtoMessage()

func (*Evaluation) ProtoReflect 

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

func (*Evaluation) Reset 

func (x *Evaluation) Reset()

func (*Evaluation) String 

func (x *Evaluation) String() string

type Evaluation_Status added in v0.1.3 

type Evaluation_Status int32
const (
	Evaluation_PENDING   Evaluation_Status = 0
	Evaluation_COMPLETE  Evaluation_Status = 1
	Evaluation_FAILED    Evaluation_Status = 2
	Evaluation_CANCELLED Evaluation_Status = 3
)

func (Evaluation_Status) Descriptor added in v0.1.3 

func (Evaluation_Status) Descriptor() protoreflect.EnumDescriptor

func (Evaluation_Status) Enum added in v0.1.3 

func (x Evaluation_Status) Enum() *Evaluation_Status

func (Evaluation_Status) EnumDescriptor deprecated added in v0.1.3 

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

Deprecated: Use Evaluation_Status.Descriptor instead.

func (Evaluation_Status) Number added in v0.1.3 

func (x Evaluation_Status) Number() protoreflect.EnumNumber

func (Evaluation_Status) String added in v0.1.3 

func (x Evaluation_Status) String() string

func (Evaluation_Status) Type added in v0.1.3 

func (Evaluation_Status) Type() protoreflect.EnumType

type Evaluation_Trigger added in v0.1.3 

type Evaluation_Trigger int32
const (
	Evaluation_UNKNOWN    Evaluation_Trigger = 0
	Evaluation_SPECCHANGE Evaluation_Trigger = 1
	Evaluation_NODECHANGE Evaluation_Trigger = 2
)

func (Evaluation_Trigger) Descriptor added in v0.1.3 

func (Evaluation_Trigger) Descriptor() protoreflect.EnumDescriptor

func (Evaluation_Trigger) Enum added in v0.1.3 

func (x Evaluation_Trigger) Enum() *Evaluation_Trigger

func (Evaluation_Trigger) EnumDescriptor deprecated added in v0.1.3 

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

Deprecated: Use Evaluation_Trigger.Descriptor instead.

func (Evaluation_Trigger) Number added in v0.1.3 

func (x Evaluation_Trigger) Number() protoreflect.EnumNumber

func (Evaluation_Trigger) String added in v0.1.3 

func (x Evaluation_Trigger) String() string

func (Evaluation_Trigger) Type added in v0.1.3 

func (Evaluation_Trigger) Type() protoreflect.EnumType

type Event added in v0.1.3 

type Event struct {
	EvalID    string               `protobuf:"bytes,1,opt,name=evalID,proto3" json:"evalID,omitempty"`
	Message   string               `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Details   map[string]string    `` /* 155-byte string literal not displayed */
	Timestamp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetDetails added in v0.1.3 

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

func (*Event) GetEvalID added in v0.1.3 

func (x *Event) GetEvalID() string

func (*Event) GetMessage added in v0.1.3 

func (x *Event) GetMessage() string

func (*Event) GetTimestamp added in v0.1.3 

func (x *Event) GetTimestamp() *timestamp.Timestamp

func (*Event) ProtoMessage added in v0.1.3 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect added in v0.1.3 

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

func (*Event) Reset added in v0.1.3 

func (x *Event) Reset()

func (*Event) String added in v0.1.3 

func (x *Event) String() string

type GetDeploymentReq added in v0.1.3 

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

func (*GetDeploymentReq) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use GetDeploymentReq.ProtoReflect.Descriptor instead.

func (*GetDeploymentReq) GetCluster added in v0.1.3 

func (x *GetDeploymentReq) GetCluster() string

func (*GetDeploymentReq) ProtoMessage added in v0.1.3 

func (*GetDeploymentReq) ProtoMessage()

func (*GetDeploymentReq) ProtoReflect added in v0.1.3 

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

func (*GetDeploymentReq) Reset added in v0.1.3 

func (x *GetDeploymentReq) Reset()

func (*GetDeploymentReq) String added in v0.1.3 

func (x *GetDeploymentReq) String() string

type Instance added in v0.1.3 

type Instance 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"`
	Namespace   string             `protobuf:"bytes,3,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	ClusterName string             `protobuf:"bytes,4,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	Group       *ClusterSpec_Group `protobuf:"bytes,5,opt,name=group,proto3" json:"group,omitempty"`
	KV          map[string]string  `` /* 145-byte string literal not displayed */
	Spec        *NodeSpec          `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	Status      Instance_Status    `protobuf:"varint,8,opt,name=status,proto3,enum=proto.Instance_Status" json:"status,omitempty"`
	Canary      bool               `protobuf:"varint,9,opt,name=canary,proto3" json:"canary,omitempty"`
	Healthy     bool               `protobuf:"varint,10,opt,name=healthy,proto3" json:"healthy,omitempty"`
	Count       int64              `protobuf:"varint,11,opt,name=count,proto3" json:"count,omitempty"`
	Ip          string             `protobuf:"bytes,12,opt,name=ip,proto3" json:"ip,omitempty"`
	// previous instance if this is replacing another one
	Prev          string                 `protobuf:"bytes,13,opt,name=prev,proto3" json:"prev,omitempty"`
	Handler       string                 `protobuf:"bytes,14,opt,name=handler,proto3" json:"handler,omitempty"`
	Sequence      int64                  `protobuf:"varint,15,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Reschedule    *Instance_Reschedule   `protobuf:"bytes,16,opt,name=reschedule,proto3" json:"reschedule,omitempty"`
	Image         string                 `protobuf:"bytes,17,opt,name=image,proto3" json:"image,omitempty"`
	Version       string                 `protobuf:"bytes,18,opt,name=version,proto3" json:"version,omitempty"`
	DnsSuffix     string                 `protobuf:"bytes,19,opt,name=dnsSuffix,proto3" json:"dnsSuffix,omitempty"`
	DeploymentID  string                 `protobuf:"bytes,20,opt,name=deploymentID,proto3" json:"deploymentID,omitempty"`
	ExitResult    *Instance_ExitResult   `protobuf:"bytes,21,opt,name=exitResult,proto3" json:"exitResult,omitempty"`
	DesiredStatus Instance_DesiredStatus `protobuf:"varint,23,opt,name=desiredStatus,proto3,enum=proto.Instance_DesiredStatus" json:"desiredStatus,omitempty"`
	Mounts        []*Instance_Mount      `protobuf:"bytes,30,rep,name=mounts,proto3" json:"mounts,omitempty"`
	// contains filtered or unexported fields
}

Instance represents a node in the Ensemble

func (*Instance) Copy added in v0.1.3 

func (n *Instance) Copy() *Instance

func (*Instance) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) FullName added in v0.1.3 

func (n *Instance) FullName() string

func (*Instance) Get added in v0.1.3 

func (n *Instance) Get(k string) string

func (*Instance) GetCanary added in v0.1.3 

func (x *Instance) GetCanary() bool

func (*Instance) GetClusterName added in v0.1.3 

func (x *Instance) GetClusterName() string

func (*Instance) GetCount added in v0.1.3 

func (x *Instance) GetCount() int64

func (*Instance) GetDeploymentID added in v0.1.3 

func (x *Instance) GetDeploymentID() string

func (*Instance) GetDesiredStatus added in v0.1.3 

func (x *Instance) GetDesiredStatus() Instance_DesiredStatus

func (*Instance) GetDnsSuffix added in v0.1.3 

func (x *Instance) GetDnsSuffix() string

func (*Instance) GetExitResult added in v0.1.3 

func (x *Instance) GetExitResult() *Instance_ExitResult

func (*Instance) GetGroup added in v0.1.3 

func (x *Instance) GetGroup() *ClusterSpec_Group

func (*Instance) GetHandler added in v0.1.3 

func (x *Instance) GetHandler() string

func (*Instance) GetHealthy added in v0.1.3 

func (x *Instance) GetHealthy() bool

func (*Instance) GetID added in v0.1.3 

func (x *Instance) GetID() string

func (*Instance) GetImage added in v0.1.3 

func (x *Instance) GetImage() string

func (*Instance) GetInt added in v0.1.3 

func (n *Instance) GetInt(k string) (int, error)

func (*Instance) GetIp added in v0.1.3 

func (x *Instance) GetIp() string

func (*Instance) GetKV added in v0.1.3 

func (x *Instance) GetKV() map[string]string

func (*Instance) GetMounts added in v0.1.3 

func (x *Instance) GetMounts() []*Instance_Mount

func (*Instance) GetName added in v0.1.3 

func (x *Instance) GetName() string

func (*Instance) GetNamespace added in v0.1.3 

func (x *Instance) GetNamespace() string

func (*Instance) GetOk added in v0.1.3 

func (n *Instance) GetOk(k string) (string, bool)

func (*Instance) GetPrev added in v0.1.3 

func (x *Instance) GetPrev() string

func (*Instance) GetReschedule added in v0.1.3 

func (x *Instance) GetReschedule() *Instance_Reschedule

func (*Instance) GetSequence added in v0.1.3 

func (x *Instance) GetSequence() int64

func (*Instance) GetSpec added in v0.1.3 

func (x *Instance) GetSpec() *NodeSpec

func (*Instance) GetStatus added in v0.1.3 

func (x *Instance) GetStatus() Instance_Status

func (*Instance) GetTrue added in v0.1.3 

func (n *Instance) GetTrue(k string) bool

func (*Instance) GetVersion added in v0.1.3 

func (x *Instance) GetVersion() string

func (*Instance) IsHealthy added in v0.1.3 

func (n *Instance) IsHealthy() bool

func (*Instance) Marshal added in v0.1.3 

func (n *Instance) Marshal() ([]byte, error)

func (*Instance) ProtoMessage added in v0.1.3 

func (*Instance) ProtoMessage()

func (*Instance) ProtoReflect added in v0.1.3 

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

func (*Instance) Reset added in v0.1.3 

func (x *Instance) Reset()

func (*Instance) Set added in v0.1.3 

func (n *Instance) Set(k, v string)

func (*Instance) SetInt added in v0.1.3 

func (n *Instance) SetInt(k string, i int)

func (*Instance) SetTrue added in v0.1.3 

func (n *Instance) SetTrue(k string)

func (*Instance) String added in v0.1.3 

func (x *Instance) String() string

func (*Instance) Unmarshal added in v0.1.3 

func (n *Instance) Unmarshal(src []byte) error

func (*Instance) Update added in v0.1.3 

func (i *Instance) Update(event isInstanceUpdate_Event) *InstanceUpdate

type InstanceUpdate added in v0.1.3 

type InstanceUpdate struct {
	ID          string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ClusterName string `protobuf:"bytes,2,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	// Types that are assignable to Event:
	//	*InstanceUpdate_Scheduled_
	//	*InstanceUpdate_Running_
	//	*InstanceUpdate_Killing_
	//	*InstanceUpdate_Failed_
	//	*InstanceUpdate_Healthy_
	Event isInstanceUpdate_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*InstanceUpdate) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use InstanceUpdate.ProtoReflect.Descriptor instead.

func (*InstanceUpdate) GetClusterName added in v0.1.3 

func (x *InstanceUpdate) GetClusterName() string

func (*InstanceUpdate) GetEvent added in v0.1.3 

func (m *InstanceUpdate) GetEvent() isInstanceUpdate_Event

func (*InstanceUpdate) GetFailed added in v0.1.3 

func (x *InstanceUpdate) GetFailed() *InstanceUpdate_Failed

func (*InstanceUpdate) GetHealthy added in v0.1.3 

func (x *InstanceUpdate) GetHealthy() *InstanceUpdate_Healthy

func (*InstanceUpdate) GetID added in v0.1.3 

func (x *InstanceUpdate) GetID() string

func (*InstanceUpdate) GetKilling added in v0.1.3 

func (x *InstanceUpdate) GetKilling() *InstanceUpdate_Killing

func (*InstanceUpdate) GetRunning added in v0.1.3 

func (x *InstanceUpdate) GetRunning() *InstanceUpdate_Running

func (*InstanceUpdate) GetScheduled added in v0.1.3 

func (x *InstanceUpdate) GetScheduled() *InstanceUpdate_Scheduled

func (*InstanceUpdate) ProtoMessage added in v0.1.3 

func (*InstanceUpdate) ProtoMessage()

func (*InstanceUpdate) ProtoReflect added in v0.1.3 

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

func (*InstanceUpdate) Reset added in v0.1.3 

func (x *InstanceUpdate) Reset()

func (*InstanceUpdate) String added in v0.1.3 

func (x *InstanceUpdate) String() string

type InstanceUpdate_Failed added in v0.1.3 

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

func (*InstanceUpdate_Failed) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use InstanceUpdate_Failed.ProtoReflect.Descriptor instead.

func (*InstanceUpdate_Failed) ProtoMessage added in v0.1.3 

func (*InstanceUpdate_Failed) ProtoMessage()

func (*InstanceUpdate_Failed) ProtoReflect added in v0.1.3 

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

func (*InstanceUpdate_Failed) Reset added in v0.1.3 

func (x *InstanceUpdate_Failed) Reset()

func (*InstanceUpdate_Failed) String added in v0.1.3 

func (x *InstanceUpdate_Failed) String() string

type InstanceUpdate_Failed_ added in v0.1.3 

type InstanceUpdate_Failed_ struct {
	Failed *InstanceUpdate_Failed `protobuf:"bytes,6,opt,name=failed,proto3,oneof"`
}

type InstanceUpdate_Healthy added in v0.1.3 

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

func (*InstanceUpdate_Healthy) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use InstanceUpdate_Healthy.ProtoReflect.Descriptor instead.

func (*InstanceUpdate_Healthy) ProtoMessage added in v0.1.3 

func (*InstanceUpdate_Healthy) ProtoMessage()

func (*InstanceUpdate_Healthy) ProtoReflect added in v0.1.3 

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

func (*InstanceUpdate_Healthy) Reset added in v0.1.3 

func (x *InstanceUpdate_Healthy) Reset()

func (*InstanceUpdate_Healthy) String added in v0.1.3 

func (x *InstanceUpdate_Healthy) String() string

type InstanceUpdate_Healthy_ added in v0.1.3 

type InstanceUpdate_Healthy_ struct {
	Healthy *InstanceUpdate_Healthy `protobuf:"bytes,7,opt,name=healthy,proto3,oneof"`
}

type InstanceUpdate_Killing added in v0.1.3 

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

func (*InstanceUpdate_Killing) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use InstanceUpdate_Killing.ProtoReflect.Descriptor instead.

func (*InstanceUpdate_Killing) ProtoMessage added in v0.1.3 

func (*InstanceUpdate_Killing) ProtoMessage()

func (*InstanceUpdate_Killing) ProtoReflect added in v0.1.3 

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

func (*InstanceUpdate_Killing) Reset added in v0.1.3 

func (x *InstanceUpdate_Killing) Reset()

func (*InstanceUpdate_Killing) String added in v0.1.3 

func (x *InstanceUpdate_Killing) String() string

type InstanceUpdate_Killing_ added in v0.1.3 

type InstanceUpdate_Killing_ struct {
	Killing *InstanceUpdate_Killing `protobuf:"bytes,5,opt,name=killing,proto3,oneof"`
}

type InstanceUpdate_Running added in v0.1.3 

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

func (*InstanceUpdate_Running) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use InstanceUpdate_Running.ProtoReflect.Descriptor instead.

func (*InstanceUpdate_Running) GetHandler added in v0.1.3 

func (x *InstanceUpdate_Running) GetHandler() string

func (*InstanceUpdate_Running) GetIp added in v0.1.3 

func (x *InstanceUpdate_Running) GetIp() string

func (*InstanceUpdate_Running) ProtoMessage added in v0.1.3 

func (*InstanceUpdate_Running) ProtoMessage()

func (*InstanceUpdate_Running) ProtoReflect added in v0.1.3 

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

func (*InstanceUpdate_Running) Reset added in v0.1.3 

func (x *InstanceUpdate_Running) Reset()

func (*InstanceUpdate_Running) String added in v0.1.3 

func (x *InstanceUpdate_Running) String() string

type InstanceUpdate_Running_ added in v0.1.3 

type InstanceUpdate_Running_ struct {
	Running *InstanceUpdate_Running `protobuf:"bytes,4,opt,name=running,proto3,oneof"`
}

type InstanceUpdate_Scheduled added in v0.1.3 

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

func (*InstanceUpdate_Scheduled) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use InstanceUpdate_Scheduled.ProtoReflect.Descriptor instead.

func (*InstanceUpdate_Scheduled) ProtoMessage added in v0.1.3 

func (*InstanceUpdate_Scheduled) ProtoMessage()

func (*InstanceUpdate_Scheduled) ProtoReflect added in v0.1.3 

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

func (*InstanceUpdate_Scheduled) Reset added in v0.1.3 

func (x *InstanceUpdate_Scheduled) Reset()

func (*InstanceUpdate_Scheduled) String added in v0.1.3 

func (x *InstanceUpdate_Scheduled) String() string

type InstanceUpdate_Scheduled_ added in v0.1.3 

type InstanceUpdate_Scheduled_ struct {
	Scheduled *InstanceUpdate_Scheduled `protobuf:"bytes,3,opt,name=scheduled,proto3,oneof"`
}

type Instance_DesiredStatus added in v0.1.3 

type Instance_DesiredStatus int32
const (
	Instance_RUN  Instance_DesiredStatus = 0
	Instance_STOP Instance_DesiredStatus = 1
)

func (Instance_DesiredStatus) Descriptor added in v0.1.3 

func (Instance_DesiredStatus) Descriptor() protoreflect.EnumDescriptor

func (Instance_DesiredStatus) Enum added in v0.1.3 

func (x Instance_DesiredStatus) Enum() *Instance_DesiredStatus

func (Instance_DesiredStatus) EnumDescriptor deprecated added in v0.1.3 

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

Deprecated: Use Instance_DesiredStatus.Descriptor instead.

func (Instance_DesiredStatus) Number added in v0.1.3 

func (x Instance_DesiredStatus) Number() protoreflect.EnumNumber

func (Instance_DesiredStatus) String added in v0.1.3 

func (x Instance_DesiredStatus) String() string

func (Instance_DesiredStatus) Type added in v0.1.3 

func (Instance_DesiredStatus) Type() protoreflect.EnumType

type Instance_ExitResult added in v0.1.3 

type Instance_ExitResult struct {
	Code  int64  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*Instance_ExitResult) Complete added in v0.1.3 

func (e *Instance_ExitResult) Complete() bool

func (*Instance_ExitResult) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use Instance_ExitResult.ProtoReflect.Descriptor instead.

func (*Instance_ExitResult) Failed added in v0.1.3 

func (e *Instance_ExitResult) Failed() bool

func (*Instance_ExitResult) GetCode added in v0.1.3 

func (x *Instance_ExitResult) GetCode() int64

func (*Instance_ExitResult) GetError added in v0.1.3 

func (x *Instance_ExitResult) GetError() string

func (*Instance_ExitResult) ProtoMessage added in v0.1.3 

func (*Instance_ExitResult) ProtoMessage()

func (*Instance_ExitResult) ProtoReflect added in v0.1.3 

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

func (*Instance_ExitResult) Reset added in v0.1.3 

func (x *Instance_ExitResult) Reset()

func (*Instance_ExitResult) String added in v0.1.3 

func (x *Instance_ExitResult) String() string

type Instance_Mount added in v0.1.3 

type Instance_Mount 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"`
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*Instance_Mount) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use Instance_Mount.ProtoReflect.Descriptor instead.

func (*Instance_Mount) GetId added in v0.1.3 

func (x *Instance_Mount) GetId() string

func (*Instance_Mount) GetName added in v0.1.3 

func (x *Instance_Mount) GetName() string

func (*Instance_Mount) GetPath added in v0.1.3 

func (x *Instance_Mount) GetPath() string

func (*Instance_Mount) ProtoMessage added in v0.1.3 

func (*Instance_Mount) ProtoMessage()

func (*Instance_Mount) ProtoReflect added in v0.1.3 

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

func (*Instance_Mount) Reset added in v0.1.3 

func (x *Instance_Mount) Reset()

func (*Instance_Mount) String added in v0.1.3 

func (x *Instance_Mount) String() string

type Instance_Reschedule added in v0.1.3 

type Instance_Reschedule struct {
	Attempts int64 `protobuf:"varint,3,opt,name=attempts,proto3" json:"attempts,omitempty"`
	// contains filtered or unexported fields
}

func (*Instance_Reschedule) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use Instance_Reschedule.ProtoReflect.Descriptor instead.

func (*Instance_Reschedule) GetAttempts added in v0.1.3 

func (x *Instance_Reschedule) GetAttempts() int64

func (*Instance_Reschedule) ProtoMessage added in v0.1.3 

func (*Instance_Reschedule) ProtoMessage()

func (*Instance_Reschedule) ProtoReflect added in v0.1.3 

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

func (*Instance_Reschedule) Reset added in v0.1.3 

func (x *Instance_Reschedule) Reset()

func (*Instance_Reschedule) String added in v0.1.3 

func (x *Instance_Reschedule) String() string

type Instance_Status added in v0.1.3 

type Instance_Status int32
const (
	Instance_UNKNOWN Instance_Status = 0 // an old instance of the ensemble
	Instance_PENDING Instance_Status = 1 // pending on the Provider to be created
	Instance_RUNNING Instance_Status = 2 // the instance is running
	Instance_TAINTED Instance_Status = 3 // the instance is tainted and ready to be stopped
	Instance_STOPPED Instance_Status = 4 // the instance is stopped
	Instance_OUT     Instance_Status = 5
)

func (Instance_Status) Descriptor added in v0.1.3 

func (Instance_Status) Descriptor() protoreflect.EnumDescriptor

func (Instance_Status) Enum added in v0.1.3 

func (x Instance_Status) Enum() *Instance_Status

func (Instance_Status) EnumDescriptor deprecated added in v0.1.3 

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

Deprecated: Use Instance_Status.Descriptor instead.

func (Instance_Status) Number added in v0.1.3 

func (x Instance_Status) Number() protoreflect.EnumNumber

func (Instance_Status) String added in v0.1.3 

func (x Instance_Status) String() string

func (Instance_Status) Type added in v0.1.3 

func (Instance_Status) Type() protoreflect.EnumType

type ListDeploymentsResp added in v0.1.3 

type ListDeploymentsResp struct {
	Deployments []*Deployment `protobuf:"bytes,1,rep,name=deployments,proto3" json:"deployments,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDeploymentsResp) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use ListDeploymentsResp.ProtoReflect.Descriptor instead.

func (*ListDeploymentsResp) GetDeployments added in v0.1.3 

func (x *ListDeploymentsResp) GetDeployments() []*Deployment

func (*ListDeploymentsResp) ProtoMessage added in v0.1.3 

func (*ListDeploymentsResp) ProtoMessage()

func (*ListDeploymentsResp) ProtoReflect added in v0.1.3 

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

func (*ListDeploymentsResp) Reset added in v0.1.3 

func (x *ListDeploymentsResp) Reset()

func (*ListDeploymentsResp) String added in v0.1.3 

func (x *ListDeploymentsResp) String() string

type NodeSpec 

type NodeSpec struct {
	Env   map[string]string `` /* 147-byte string literal not displayed */
	Files []*NodeSpec_File  `protobuf:"bytes,4,rep,name=files,proto3" json:"files,omitempty"`
	Args  []string          `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	Cmd   string            `protobuf:"bytes,6,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeSpec) AddEnv 

func (b *NodeSpec) AddEnv(k, v string)

func (*NodeSpec) AddEnvList 

func (b *NodeSpec) AddEnvList(l []string)

func (*NodeSpec) AddEnvMap 

func (b *NodeSpec) AddEnvMap(m map[string]string)

func (*NodeSpec) AddFile 

func (b *NodeSpec) AddFile(path string, content string)

func (*NodeSpec) Copy 

func (b *NodeSpec) Copy() *NodeSpec

func (*NodeSpec) Descriptor deprecated 

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

Deprecated: Use NodeSpec.ProtoReflect.Descriptor instead.

func (*NodeSpec) GetArgs added in v0.1.3 

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

func (*NodeSpec) GetCmd 

func (x *NodeSpec) GetCmd() string

func (*NodeSpec) GetEnv 

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

func (*NodeSpec) GetFiles 

func (x *NodeSpec) GetFiles() []*NodeSpec_File

func (*NodeSpec) ProtoMessage 

func (*NodeSpec) ProtoMessage()

func (*NodeSpec) ProtoReflect 

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

func (*NodeSpec) Reset 

func (x *NodeSpec) Reset()

func (*NodeSpec) String 

func (x *NodeSpec) String() string

type NodeSpec_File added in v0.1.3 

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

func (*NodeSpec_File) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use NodeSpec_File.ProtoReflect.Descriptor instead.

func (*NodeSpec_File) GetContent added in v0.1.3 

func (x *NodeSpec_File) GetContent() string

func (*NodeSpec_File) GetName added in v0.1.3 

func (x *NodeSpec_File) GetName() string

func (*NodeSpec_File) ProtoMessage added in v0.1.3 

func (*NodeSpec_File) ProtoMessage()

func (*NodeSpec_File) ProtoReflect added in v0.1.3 

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

func (*NodeSpec_File) Reset added in v0.1.3 

func (x *NodeSpec_File) Reset()

func (*NodeSpec_File) String added in v0.1.3 

func (x *NodeSpec_File) String() string

type Plan 

type Plan struct {
	EvalID     string       `protobuf:"bytes,1,opt,name=evalID,proto3" json:"evalID,omitempty"`
	Cluster    *ClusterSpec `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Deployment *Deployment  `protobuf:"bytes,3,opt,name=deployment,proto3" json:"deployment,omitempty"`
	NodeUpdate []*Instance  `protobuf:"bytes,4,rep,name=nodeUpdate,proto3" json:"nodeUpdate,omitempty"`
	Status     string       `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	Done       bool         `protobuf:"varint,7,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

Plan after a reconcile

func (*Plan) Descriptor deprecated 

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

Deprecated: Use Plan.ProtoReflect.Descriptor instead.

func (*Plan) GetCluster 

func (x *Plan) GetCluster() *ClusterSpec

func (*Plan) GetDeployment added in v0.1.3 

func (x *Plan) GetDeployment() *Deployment

func (*Plan) GetDone added in v0.1.3 

func (x *Plan) GetDone() bool

func (*Plan) GetEvalID added in v0.1.3 

func (x *Plan) GetEvalID() string

func (*Plan) GetNodeUpdate added in v0.1.3 

func (x *Plan) GetNodeUpdate() []*Instance

func (*Plan) GetStatus added in v0.1.3 

func (x *Plan) GetStatus() string

func (*Plan) ProtoMessage 

func (*Plan) ProtoMessage()

func (*Plan) ProtoReflect 

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

func (*Plan) Reset 

func (x *Plan) Reset()

func (*Plan) String 

func (x *Plan) String() string

type ResourceSpec added in v0.1.1 

type ResourceSpec struct {

	// name of the cluster
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// name of the resource in the backend
	Resource string `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	// params are the params to configure the resource (in JSON)
	Params *Spec `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

Description of the resource

func (*ResourceSpec) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use ResourceSpec.ProtoReflect.Descriptor instead.

func (*ResourceSpec) GetCluster added in v0.1.1 

func (x *ResourceSpec) GetCluster() string

func (*ResourceSpec) GetClusterID added in v0.1.3 

func (r *ResourceSpec) GetClusterID() string

func (*ResourceSpec) GetParams added in v0.1.1 

func (x *ResourceSpec) GetParams() *Spec

func (*ResourceSpec) GetResource added in v0.1.1 

func (x *ResourceSpec) GetResource() string

func (*ResourceSpec) ProtoMessage added in v0.1.1 

func (*ResourceSpec) ProtoMessage()

func (*ResourceSpec) ProtoReflect added in v0.1.1 

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

func (*ResourceSpec) Reset added in v0.1.1 

func (x *ResourceSpec) Reset()

func (*ResourceSpec) String added in v0.1.1 

func (x *ResourceSpec) String() string

type Spec added in v0.1.3 

type Spec struct {

	// Types that are assignable to Block:
	//	*Spec_BlockValue
	//	*Spec_Literal_
	//	*Spec_Array_
	Block isSpec_Block `protobuf_oneof:"block"`
	// contains filtered or unexported fields
}

func ArraySpec added in v0.1.3 

func ArraySpec(values []*Spec) *Spec

func BlockSpec added in v0.1.3 

func BlockSpec(block *Spec_Block) *Spec

func EmptySpec added in v0.1.3 

func EmptySpec() *Spec

func LiteralSpec added in v0.1.3 

func LiteralSpec(l *Spec_Literal) *Spec

LiteralSpec wraps the literal and returns a spec.

func (*Spec) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use Spec.ProtoReflect.Descriptor instead.

func (*Spec) GetArray added in v0.1.3 

func (x *Spec) GetArray() *Spec_Array

func (*Spec) GetBlock added in v0.1.3 

func (m *Spec) GetBlock() isSpec_Block

func (*Spec) GetBlockValue added in v0.1.3 

func (x *Spec) GetBlockValue() *Spec_Block

func (*Spec) GetLiteral added in v0.1.3 

func (x *Spec) GetLiteral() *Spec_Literal

func (*Spec) ProtoMessage added in v0.1.3 

func (*Spec) ProtoMessage()

func (*Spec) ProtoReflect added in v0.1.3 

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

func (*Spec) Reset added in v0.1.3 

func (x *Spec) Reset()

func (*Spec) String added in v0.1.3 

func (x *Spec) String() string

type Spec_Array added in v0.1.3 

type Spec_Array struct {
	Values []*Spec `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Spec_Array) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use Spec_Array.ProtoReflect.Descriptor instead.

func (*Spec_Array) GetValues added in v0.1.3 

func (x *Spec_Array) GetValues() []*Spec

func (*Spec_Array) ProtoMessage added in v0.1.3 

func (*Spec_Array) ProtoMessage()

func (*Spec_Array) ProtoReflect added in v0.1.3 

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

func (*Spec_Array) Reset added in v0.1.3 

func (x *Spec_Array) Reset()

func (*Spec_Array) String added in v0.1.3 

func (x *Spec_Array) String() string

type Spec_Array_ added in v0.1.3 

type Spec_Array_ struct {
	Array *Spec_Array `protobuf:"bytes,3,opt,name=array,proto3,oneof"`
}

type Spec_Block added in v0.1.3 

type Spec_Block struct {
	Attrs map[string]*Spec `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Spec_Block) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use Spec_Block.ProtoReflect.Descriptor instead.

func (*Spec_Block) GetAttrs added in v0.1.3 

func (x *Spec_Block) GetAttrs() map[string]*Spec

func (*Spec_Block) ProtoMessage added in v0.1.3 

func (*Spec_Block) ProtoMessage()

func (*Spec_Block) ProtoReflect added in v0.1.3 

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

func (*Spec_Block) Reset added in v0.1.3 

func (x *Spec_Block) Reset()

func (*Spec_Block) String added in v0.1.3 

func (x *Spec_Block) String() string

type Spec_BlockValue added in v0.1.3 

type Spec_BlockValue struct {
	BlockValue *Spec_Block `protobuf:"bytes,1,opt,name=block_value,json=blockValue,proto3,oneof"`
}

type Spec_Literal added in v0.1.3 

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

func (*Spec_Literal) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use Spec_Literal.ProtoReflect.Descriptor instead.

func (*Spec_Literal) GetValue added in v0.1.3 

func (x *Spec_Literal) GetValue() string

func (*Spec_Literal) ProtoMessage added in v0.1.3 

func (*Spec_Literal) ProtoMessage()

func (*Spec_Literal) ProtoReflect added in v0.1.3 

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

func (*Spec_Literal) Reset added in v0.1.3 

func (x *Spec_Literal) Reset()

func (*Spec_Literal) String added in v0.1.3 

func (x *Spec_Literal) String() string

type Spec_Literal_ added in v0.1.3 

type Spec_Literal_ struct {
	Literal *Spec_Literal `protobuf:"bytes,2,opt,name=literal,proto3,oneof"`
}

type Task 

type Task struct {

	// Name of the cluster
	DeploymentID string `protobuf:"bytes,1,opt,name=deploymentID,proto3" json:"deploymentID,omitempty"`
	// Reference to the resource
	ComponentID string `protobuf:"bytes,2,opt,name=componentID,proto3" json:"componentID,omitempty"`
	// Number of the sequence
	Sequence int64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

Task is a task received from the state

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetComponentID added in v0.1.3 

func (x *Task) GetComponentID() string

func (*Task) GetDeploymentID added in v0.1.3 

func (x *Task) GetDeploymentID() string

func (*Task) GetSequence added in v0.1.3 

func (x *Task) GetSequence() int64

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 UnimplementedEnsembleServiceServer added in v0.1.1 

type UnimplementedEnsembleServiceServer struct {
}

UnimplementedEnsembleServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEnsembleServiceServer) Apply added in v0.1.1 

func (UnimplementedEnsembleServiceServer) Apply(context.Context, *Component) (*Component, error)

func (UnimplementedEnsembleServiceServer) GetDeployment added in v0.1.3 

func (UnimplementedEnsembleServiceServer) GetDeployment(context.Context, *GetDeploymentReq) (*Deployment, error)

func (UnimplementedEnsembleServiceServer) ListDeployments added in v0.1.3 

func (UnimplementedEnsembleServiceServer) ListDeployments(context.Context, *empty.Empty) (*ListDeploymentsResp, error)

type UnsafeEnsembleServiceServer added in v0.1.3 

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

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

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.