proto

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2021 License: MPL-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for Component_Status.

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

Enum value maps for Component_Action.

View Source 
var (
	Node_NodeState_name = map[int32]string{
		0: "UNKNOWN",
		1: "INITIALIZED",
		2: "PENDING",
		3: "RUNNING",
		4: "TAINTED",
		5: "FAILED",
		6: "DOWN",
	}
	Node_NodeState_value = map[string]int32{
		"UNKNOWN":     0,
		"INITIALIZED": 1,
		"PENDING":     2,
		"RUNNING":     3,
		"TAINTED":     4,
		"FAILED":      5,
		"DOWN":        6,
	}
)

Enum value maps for Node_NodeState.

View Source 
var (
	Cluster_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "SCALING",
		2: "COMPLETE",
	}
	Cluster_Status_value = map[string]int32{
		"UNKNOWN":  0,
		"SCALING":  1,
		"COMPLETE": 2,
	}
)

Enum value maps for Cluster_Status.

View Source 
var File_operator_proto_structs_proto protoreflect.FileDescriptor

Functions

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

func RegisterEnsembleServiceServer(s *grpc.Server, srv EnsembleServiceServer)

Types

type Cluster 

type Cluster struct {

	// name of the cluster
	Name      string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Backend   string         `protobuf:"bytes,3,opt,name=backend,proto3" json:"backend,omitempty"`
	Nodes     []*Node        `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Status    Cluster_Status `protobuf:"varint,5,opt,name=status,proto3,enum=proto.Cluster_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Instance of a cluster

func (*Cluster) AddNode 

func (c *Cluster) AddNode(n *Node)

func (*Cluster) Copy 

func (c *Cluster) Copy() *Cluster

func (*Cluster) DelNodeAtIndx 

func (c *Cluster) DelNodeAtIndx(i int)

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetBackend added in v0.1.1 

func (x *Cluster) GetBackend() string

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetNamespace 

func (x *Cluster) GetNamespace() string

func (*Cluster) GetNodes 

func (x *Cluster) GetNodes() []*Node

func (*Cluster) GetStatus added in v0.1.2 

func (x *Cluster) GetStatus() Cluster_Status

func (*Cluster) NewNode 

func (c *Cluster) NewNode() *Node

func (*Cluster) NodeAtIndex 

func (c *Cluster) NodeAtIndex(ID string) int

func (*Cluster) NodeByID added in v0.1.2 

func (c *Cluster) NodeByID(ID string) (*Node, bool)

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) Size 

func (c *Cluster) Size() int

func (*Cluster) String 

func (x *Cluster) String() 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"`
	Sets    []*ClusterSpec_Set `protobuf:"bytes,4,rep,name=sets,proto3" json:"sets,omitempty"`
	// contains filtered or unexported fields
}

Description of the cluster

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) GetSets added in v0.1.2 

func (x *ClusterSpec) GetSets() []*ClusterSpec_Set

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_Set added in v0.1.2 

type ClusterSpec_Set struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Replicas int64  `protobuf:"varint,2,opt,name=replicas,proto3" json:"replicas,omitempty"`
	Type     string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterSpec_Set) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use ClusterSpec_Set.ProtoReflect.Descriptor instead.

func (*ClusterSpec_Set) GetName added in v0.1.2 

func (x *ClusterSpec_Set) GetName() string

func (*ClusterSpec_Set) GetReplicas added in v0.1.2 

func (x *ClusterSpec_Set) GetReplicas() int64

func (*ClusterSpec_Set) GetType added in v0.1.2 

func (x *ClusterSpec_Set) GetType() string

func (*ClusterSpec_Set) ProtoMessage added in v0.1.2 

func (*ClusterSpec_Set) ProtoMessage()

func (*ClusterSpec_Set) ProtoReflect added in v0.1.2 

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

func (*ClusterSpec_Set) Reset added in v0.1.2 

func (x *ClusterSpec_Set) Reset()

func (*ClusterSpec_Set) String added in v0.1.2 

func (x *ClusterSpec_Set) String() string

type Cluster_Status added in v0.1.2 

type Cluster_Status int32
const (
	Cluster_UNKNOWN  Cluster_Status = 0
	Cluster_SCALING  Cluster_Status = 1
	Cluster_COMPLETE Cluster_Status = 2
)

func (Cluster_Status) Descriptor added in v0.1.2 

func (Cluster_Status) Descriptor() protoreflect.EnumDescriptor

func (Cluster_Status) Enum added in v0.1.2 

func (x Cluster_Status) Enum() *Cluster_Status

func (Cluster_Status) EnumDescriptor deprecated added in v0.1.2 

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

Deprecated: Use Cluster_Status.Descriptor instead.

func (Cluster_Status) Number added in v0.1.2 

func (x Cluster_Status) Number() protoreflect.EnumNumber

func (Cluster_Status) String added in v0.1.2 

func (x Cluster_Status) String() string

func (Cluster_Status) Type added in v0.1.2 

func (Cluster_Status) Type() protoreflect.EnumType

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 */
	// contains filtered or unexported fields
}

Component is like a snapshot or something. AKA Evaluation

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

type ComponentTask added in v0.1.2 

type ComponentTask struct {
	Old *Component `protobuf:"bytes,1,opt,name=old,proto3" json:"old,omitempty"`
	New *Component `protobuf:"bytes,2,opt,name=new,proto3" json:"new,omitempty"`
	// contains filtered or unexported fields
}

func (*ComponentTask) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use ComponentTask.ProtoReflect.Descriptor instead.

func (*ComponentTask) GetNew added in v0.1.2 

func (x *ComponentTask) GetNew() *Component

func (*ComponentTask) GetOld added in v0.1.2 

func (x *ComponentTask) GetOld() *Component

func (*ComponentTask) ProtoMessage added in v0.1.2 

func (*ComponentTask) ProtoMessage()

func (*ComponentTask) ProtoReflect added in v0.1.2 

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

func (*ComponentTask) Reset added in v0.1.2 

func (x *ComponentTask) Reset()

func (*ComponentTask) String added in v0.1.2 

func (x *ComponentTask) String() string

type Component_Action added in v0.1.1 

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

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
)

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 Context added in v0.1.2 

type Context struct {
	Plan    *Plan     `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"`
	Set     *Plan_Set `protobuf:"bytes,2,opt,name=set,proto3" json:"set,omitempty"`
	Cluster *Cluster  `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*Context) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use Context.ProtoReflect.Descriptor instead.

func (*Context) GetCluster added in v0.1.2 

func (x *Context) GetCluster() *Cluster

func (*Context) GetPlan added in v0.1.2 

func (x *Context) GetPlan() *Plan

func (*Context) GetSet added in v0.1.2 

func (x *Context) GetSet() *Plan_Set

func (*Context) ProtoMessage added in v0.1.2 

func (*Context) ProtoMessage()

func (*Context) ProtoReflect added in v0.1.2 

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

func (*Context) Reset added in v0.1.2 

func (x *Context) Reset()

func (*Context) String added in v0.1.2 

func (x *Context) String() string

type EnsembleServiceClient added in v0.1.1 

type EnsembleServiceClient interface {
	Apply(ctx context.Context, in *Component, opts ...grpc.CallOption) (*Component, error)
}

EnsembleServiceClient is the client API for EnsembleService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#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)
}

EnsembleServiceServer is the server API for EnsembleService service.

type Node 

type Node struct {
	ID        string            `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Addr      string            `protobuf:"bytes,2,opt,name=Addr,proto3" json:"Addr,omitempty"`
	Handle    string            `protobuf:"bytes,3,opt,name=Handle,proto3" json:"Handle,omitempty"`
	Namespace string            `protobuf:"bytes,4,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	Nodeset   string            `protobuf:"bytes,5,opt,name=Nodeset,proto3" json:"Nodeset,omitempty"`
	Nodetype  string            `protobuf:"bytes,6,opt,name=Nodetype,proto3" json:"Nodetype,omitempty"`
	State     Node_NodeState    `protobuf:"varint,7,opt,name=State,proto3,enum=proto.Node_NodeState" json:"State,omitempty"`
	Cluster   string            `protobuf:"bytes,8,opt,name=Cluster,proto3" json:"Cluster,omitempty"`
	Spec      *Node_NodeSpec    `protobuf:"bytes,9,opt,name=Spec,proto3" json:"Spec,omitempty"`
	KV        map[string]string `` /* 146-byte string literal not displayed */
	Mounts    []*Node_Mount     `protobuf:"bytes,11,rep,name=Mounts,proto3" json:"Mounts,omitempty"`
	Ready     bool              `protobuf:"varint,12,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Copy 

func (n *Node) Copy() *Node

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) Equal 

func (n *Node) Equal(nn *Node) bool

func (*Node) FullName 

func (n *Node) FullName() string

func (*Node) Get 

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

func (*Node) GetAddr 

func (x *Node) GetAddr() string

func (*Node) GetCluster 

func (x *Node) GetCluster() string

func (*Node) GetHandle 

func (x *Node) GetHandle() string

func (*Node) GetID 

func (x *Node) GetID() string

func (*Node) GetKV 

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

func (*Node) GetMounts 

func (x *Node) GetMounts() []*Node_Mount

func (*Node) GetNamespace 

func (x *Node) GetNamespace() string

func (*Node) GetNodeset 

func (x *Node) GetNodeset() string

func (*Node) GetNodetype 

func (x *Node) GetNodetype() string

func (*Node) GetOk 

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

func (*Node) GetReady added in v0.1.2 

func (x *Node) GetReady() bool

func (*Node) GetSpec 

func (x *Node) GetSpec() *Node_NodeSpec

func (*Node) GetState 

func (x *Node) GetState() Node_NodeState

func (*Node) Marshal 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) Set 

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

func (*Node) String 

func (x *Node) String() string

func (*Node) Unmarshal 

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

TODO: Use protobuf for this

type NodeUpdate added in v0.1.1 

type NodeUpdate struct {
	Id    string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State Node_NodeState `protobuf:"varint,2,opt,name=state,proto3,enum=proto.Node_NodeState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use NodeUpdate.ProtoReflect.Descriptor instead.

func (*NodeUpdate) GetId added in v0.1.1 

func (x *NodeUpdate) GetId() string

func (*NodeUpdate) GetState added in v0.1.1 

func (x *NodeUpdate) GetState() Node_NodeState

func (*NodeUpdate) ProtoMessage added in v0.1.1 

func (*NodeUpdate) ProtoMessage()

func (*NodeUpdate) ProtoReflect added in v0.1.1 

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

func (*NodeUpdate) Reset added in v0.1.1 

func (x *NodeUpdate) Reset()

func (*NodeUpdate) String added in v0.1.1 

func (x *NodeUpdate) String() string

type Node_Mount added in v0.1.1 

type Node_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 (*Node_Mount) Copy added in v0.1.1 

func (m *Node_Mount) Copy() *Node_Mount

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

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

Deprecated: Use Node_Mount.ProtoReflect.Descriptor instead.

func (*Node_Mount) GetId added in v0.1.1 

func (x *Node_Mount) GetId() string

func (*Node_Mount) GetName added in v0.1.1 

func (x *Node_Mount) GetName() string

func (*Node_Mount) GetPath added in v0.1.1 

func (x *Node_Mount) GetPath() string

func (*Node_Mount) ProtoMessage added in v0.1.1 

func (*Node_Mount) ProtoMessage()

func (*Node_Mount) ProtoReflect added in v0.1.1 

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

func (*Node_Mount) Reset added in v0.1.1 

func (x *Node_Mount) Reset()

func (*Node_Mount) String added in v0.1.1 

func (x *Node_Mount) String() string

type Node_NodeSpec added in v0.1.1 

type Node_NodeSpec struct {
	Env     map[string]string `` /* 147-byte string literal not displayed */
	Files   map[string]string `` /* 151-byte string literal not displayed */
	Image   string            `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	Version string            `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Cmd     []string          `protobuf:"bytes,5,rep,name=cmd,proto3" json:"cmd,omitempty"`
	// contains filtered or unexported fields
}

func (*Node_NodeSpec) AddEnv added in v0.1.1 

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

func (*Node_NodeSpec) AddEnvList added in v0.1.1 

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

func (*Node_NodeSpec) AddEnvMap added in v0.1.1 

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

func (*Node_NodeSpec) AddFile added in v0.1.1 

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

func (*Node_NodeSpec) Copy added in v0.1.1 

func (b *Node_NodeSpec) Copy() *Node_NodeSpec

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

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

Deprecated: Use Node_NodeSpec.ProtoReflect.Descriptor instead.

func (*Node_NodeSpec) GetCmd added in v0.1.1 

func (x *Node_NodeSpec) GetCmd() []string

func (*Node_NodeSpec) GetEnv added in v0.1.1 

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

func (*Node_NodeSpec) GetFiles added in v0.1.1 

func (x *Node_NodeSpec) GetFiles() map[string]string

func (*Node_NodeSpec) GetImage added in v0.1.1 

func (x *Node_NodeSpec) GetImage() string

func (*Node_NodeSpec) GetVersion added in v0.1.1 

func (x *Node_NodeSpec) GetVersion() string

func (*Node_NodeSpec) ProtoMessage added in v0.1.1 

func (*Node_NodeSpec) ProtoMessage()

func (*Node_NodeSpec) ProtoReflect added in v0.1.1 

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

func (*Node_NodeSpec) Reset added in v0.1.1 

func (x *Node_NodeSpec) Reset()

func (*Node_NodeSpec) String added in v0.1.1 

func (x *Node_NodeSpec) String() string

type Node_NodeState added in v0.1.1 

type Node_NodeState int32
const (
	Node_UNKNOWN     Node_NodeState = 0
	Node_INITIALIZED Node_NodeState = 1
	Node_PENDING     Node_NodeState = 2
	Node_RUNNING     Node_NodeState = 3
	Node_TAINTED     Node_NodeState = 4
	Node_FAILED      Node_NodeState = 5
	Node_DOWN        Node_NodeState = 6
)

func (Node_NodeState) Descriptor added in v0.1.1 

func (Node_NodeState) Descriptor() protoreflect.EnumDescriptor

func (Node_NodeState) Enum added in v0.1.1 

func (x Node_NodeState) Enum() *Node_NodeState

func (Node_NodeState) EnumDescriptor deprecated added in v0.1.1 

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

Deprecated: Use Node_NodeState.Descriptor instead.

func (Node_NodeState) Number added in v0.1.1 

func (x Node_NodeState) Number() protoreflect.EnumNumber

func (Node_NodeState) String added in v0.1.1 

func (x Node_NodeState) String() string

func (Node_NodeState) Type added in v0.1.1 

func (Node_NodeState) Type() protoreflect.EnumType

type Plan 

type Plan struct {
	Bootstrap bool        `protobuf:"varint,1,opt,name=Bootstrap,proto3" json:"Bootstrap,omitempty"`
	Sets      []*Plan_Set `protobuf:"bytes,2,rep,name=sets,proto3" json:"sets,omitempty"`
	// contains filtered or unexported fields
}

func (*Plan) Descriptor deprecated 

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

Deprecated: Use Plan.ProtoReflect.Descriptor instead.

func (*Plan) GetBootstrap 

func (x *Plan) GetBootstrap() bool

func (*Plan) GetSets added in v0.1.2 

func (x *Plan) GetSets() []*Plan_Set

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 Plan_Set added in v0.1.2 

type Plan_Set struct {
	Type        string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // organized by type of cluster
	AddNodes    []*Node  `protobuf:"bytes,2,rep,name=AddNodes,proto3" json:"AddNodes,omitempty"`
	DelNodesNum int64    `protobuf:"varint,3,opt,name=DelNodesNum,proto3" json:"DelNodesNum,omitempty"`
	DelNodes    []string `protobuf:"bytes,4,rep,name=DelNodes,proto3" json:"DelNodes,omitempty"`
	UpdateNodes []string `protobuf:"bytes,5,rep,name=UpdateNodes,proto3" json:"UpdateNodes,omitempty"`
	// contains filtered or unexported fields
}

func (*Plan_Set) Add added in v0.1.2 

func (p *Plan_Set) Add(n *Node)

func (*Plan_Set) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use Plan_Set.ProtoReflect.Descriptor instead.

func (*Plan_Set) GetAddNodes added in v0.1.2 

func (x *Plan_Set) GetAddNodes() []*Node

func (*Plan_Set) GetDelNodes added in v0.1.2 

func (x *Plan_Set) GetDelNodes() []string

func (*Plan_Set) GetDelNodesNum added in v0.1.2 

func (x *Plan_Set) GetDelNodesNum() int64

func (*Plan_Set) GetType added in v0.1.2 

func (x *Plan_Set) GetType() string

func (*Plan_Set) GetUpdateNodes added in v0.1.2 

func (x *Plan_Set) GetUpdateNodes() []string

func (*Plan_Set) ProtoMessage added in v0.1.2 

func (*Plan_Set) ProtoMessage()

func (*Plan_Set) ProtoReflect added in v0.1.2 

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

func (*Plan_Set) Reset added in v0.1.2 

func (x *Plan_Set) Reset()

func (*Plan_Set) String added in v0.1.2 

func (x *Plan_Set) String() string

type ResourceSpec added in v0.1.1 

type ResourceSpec struct {

	// name of the cluster
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// name of the resource in the backend
	Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	// params are the params to configure the resource (in JSON)
	Params string `protobuf:"bytes,4,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) GetParams added in v0.1.1 

func (x *ResourceSpec) GetParams() string

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

type UnimplementedEnsembleServiceServer struct {
}

UnimplementedEnsembleServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEnsembleServiceServer) Apply added in v0.1.1 

func (*UnimplementedEnsembleServiceServer) Apply(context.Context, *Component) (*Component, 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.