nodecmd

Documentation

Index

• Variables
• type AddNode
  • func (*AddNode) Descriptor() ([]byte, []int)
  • func (x *AddNode) GetNode() *v1.Node
  • func (*AddNode) ProtoMessage()
  • func (x *AddNode) ProtoReflect() protoreflect.Message
  • func (x *AddNode) Reset()
  • func (x *AddNode) String() string
• type AssignTopic
  • func (*AssignTopic) Descriptor() ([]byte, []int)
  • func (x *AssignTopic) GetNodeName() string
  • func (x *AssignTopic) GetTopicName() string
  • func (*AssignTopic) ProtoMessage()
  • func (x *AssignTopic) ProtoReflect() protoreflect.Message
  • func (x *AssignTopic) Reset()
  • func (x *AssignTopic) String() string
• type RemoveNode
  • func (*RemoveNode) Descriptor() ([]byte, []int)
  • func (x *RemoveNode) GetName() string
  • func (*RemoveNode) ProtoMessage()
  • func (x *RemoveNode) ProtoReflect() protoreflect.Message
  • func (x *RemoveNode) Reset()
  • func (x *RemoveNode) String() string

Variables

var File_arrebato_node_command_v1_command_proto protoreflect.FileDescriptor

Types

type AddNode

type AddNode struct {
	Node *v1.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

The AddNode message is a command indicating that a node has been added to the cluster.

func (*AddNode) Descriptor

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

Deprecated: Use AddNode.ProtoReflect.Descriptor instead.

func (*AddNode) GetNode

func (x *AddNode) GetNode() *v1.Node

func (*AddNode) ProtoMessage

func (*AddNode) ProtoMessage()

func (*AddNode) ProtoReflect

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

func (*AddNode) Reset

func (x *AddNode) Reset()

func (*AddNode) String

func (x *AddNode) String() string

type AssignTopic

type AssignTopic struct {
	NodeName  string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	TopicName string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// contains filtered or unexported fields
}

The AssignTopic message is a command indicating that a topic has been assigned to a given node.

func (*AssignTopic) Descriptor

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

Deprecated: Use AssignTopic.ProtoReflect.Descriptor instead.

func (*AssignTopic) GetNodeName

func (x *AssignTopic) GetNodeName() string

func (*AssignTopic) GetTopicName

func (x *AssignTopic) GetTopicName() string

func (*AssignTopic) ProtoMessage

func (*AssignTopic) ProtoMessage()

func (*AssignTopic) ProtoReflect

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

func (*AssignTopic) Reset

func (x *AssignTopic) Reset()

func (*AssignTopic) String

func (x *AssignTopic) String() string

type RemoveNode

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

The RemoveNode message is a command indicating that a node has been removed from the cluster.

func (*RemoveNode) Descriptor

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

Deprecated: Use RemoveNode.ProtoReflect.Descriptor instead.

func (*RemoveNode) GetName

func (x *RemoveNode) GetName() string

func (*RemoveNode) ProtoMessage

func (*RemoveNode) ProtoMessage()

func (*RemoveNode) ProtoReflect

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

func (*RemoveNode) Reset

func (x *RemoveNode) Reset()

func (*RemoveNode) String

func (x *RemoveNode) String() string