commands

package
v0.0.0-...-c9d8e2f Latest Latest
Warning

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

Go to latest
Published: Apr 1, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CommandManager_GetNodes_FullMethodName                 = "/tailsys.CommandManager/GetNodes"
	CommandManager_SendCommandToNodes_FullMethodName       = "/tailsys.CommandManager/SendCommandToNodes"
	CommandManager_SendCommandToNodesStream_FullMethodName = "/tailsys.CommandManager/SendCommandToNodesStream"
)
View Source
const (
	CommandRunner_Command_FullMethodName = "/tailsys.CommandRunner/Command"
)
View Source
const (
	Pinger_Ping_FullMethodName = "/tailsys.Pinger/Ping"
)
View Source
const (
	Registration_Register_FullMethodName = "/tailsys.Registration/Register"
)

Variables

View Source
var (
	OSType_name = map[int32]string{
		0: "OS_TYPE_UNSPECIFIED",
		1: "LINUX",
		2: "MACOS",
		3: "WINDOWS",
	}
	OSType_value = map[string]int32{
		"OS_TYPE_UNSPECIFIED": 0,
		"LINUX":               1,
		"MACOS":               2,
		"WINDOWS":             3,
	}
)

Enum value maps for OSType.

View Source
var (
	SystemType_name = map[int32]string{
		0: "COORDINATION_SERVER",
		1: "CLIENT",
		2: "CLI",
	}
	SystemType_value = map[string]int32{
		"COORDINATION_SERVER": 0,
		"CLIENT":              1,
		"CLI":                 2,
	}
)

Enum value maps for SystemType.

View Source
var CommandManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tailsys.CommandManager",
	HandlerType: (*CommandManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetNodes",
			Handler:    _CommandManager_GetNodes_Handler,
		},
		{
			MethodName: "SendCommandToNodes",
			Handler:    _CommandManager_SendCommandToNodes_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SendCommandToNodesStream",
			Handler:       _CommandManager_SendCommandToNodesStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "command.proto",
}

CommandManager_ServiceDesc is the grpc.ServiceDesc for CommandManager 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 CommandRunner_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tailsys.CommandRunner",
	HandlerType: (*CommandRunnerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Command",
			Handler:    _CommandRunner_Command_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "command.proto",
}

CommandRunner_ServiceDesc is the grpc.ServiceDesc for CommandRunner 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_command_proto protoreflect.FileDescriptor
View Source
var File_sysinfo_proto protoreflect.FileDescriptor
View Source
var Pinger_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tailsys.Pinger",
	HandlerType: (*PingerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Pinger_Ping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sysinfo.proto",
}

Pinger_ServiceDesc is the grpc.ServiceDesc for Pinger 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 Registration_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tailsys.Registration",
	HandlerType: (*RegistrationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Registration_Register_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sysinfo.proto",
}

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

Functions

func RegisterCommandManagerServer

func RegisterCommandManagerServer(s grpc.ServiceRegistrar, srv CommandManagerServer)

func RegisterCommandRunnerServer

func RegisterCommandRunnerServer(s grpc.ServiceRegistrar, srv CommandRunnerServer)

func RegisterPingerServer

func RegisterPingerServer(s grpc.ServiceRegistrar, srv PingerServer)

func RegisterRegistrationServer

func RegisterRegistrationServer(s grpc.ServiceRegistrar, srv RegistrationServer)

Types

type AggregateResponses

type AggregateResponses struct {
	Response []*CommandResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregateResponses) Descriptor deprecated

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

Deprecated: Use AggregateResponses.ProtoReflect.Descriptor instead.

func (*AggregateResponses) GetResponse

func (x *AggregateResponses) GetResponse() []*CommandResponse

func (*AggregateResponses) ProtoMessage

func (*AggregateResponses) ProtoMessage()

func (*AggregateResponses) ProtoReflect

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

func (*AggregateResponses) Reset

func (x *AggregateResponses) Reset()

func (*AggregateResponses) String

func (x *AggregateResponses) String() string

type CommandManagerClient

type CommandManagerClient interface {
	GetNodes(ctx context.Context, in *NodeQuery, opts ...grpc.CallOption) (*NodeQueryResponse, error)
	SendCommandToNodes(ctx context.Context, in *CommanderRequest, opts ...grpc.CallOption) (*AggregateResponses, error)
	SendCommandToNodesStream(ctx context.Context, in *CommanderRequest, opts ...grpc.CallOption) (CommandManager_SendCommandToNodesStreamClient, error)
}

CommandManagerClient is the client API for CommandManager service.

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

type CommandManagerServer

type CommandManagerServer interface {
	GetNodes(context.Context, *NodeQuery) (*NodeQueryResponse, error)
	SendCommandToNodes(context.Context, *CommanderRequest) (*AggregateResponses, error)
	SendCommandToNodesStream(*CommanderRequest, CommandManager_SendCommandToNodesStreamServer) error
	// contains filtered or unexported methods
}

CommandManagerServer is the server API for CommandManager service. All implementations must embed UnimplementedCommandManagerServer for forward compatibility

type CommandManager_SendCommandToNodesStreamClient

type CommandManager_SendCommandToNodesStreamClient interface {
	Recv() (*CommandResponse, error)
	grpc.ClientStream
}

type CommandManager_SendCommandToNodesStreamServer

type CommandManager_SendCommandToNodesStreamServer interface {
	Send(*CommandResponse) error
	grpc.ServerStream
}

type CommandRequest

type CommandRequest struct {
	Requested *timestamp.Timestamp `protobuf:"bytes,1,opt,name=requested,proto3" json:"requested,omitempty"`
	Command   string               `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	Key       *Key                 `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandRequest) Descriptor deprecated

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

Deprecated: Use CommandRequest.ProtoReflect.Descriptor instead.

func (*CommandRequest) GetCommand

func (x *CommandRequest) GetCommand() string

func (*CommandRequest) GetKey

func (x *CommandRequest) GetKey() *Key

func (*CommandRequest) GetRequested

func (x *CommandRequest) GetRequested() *timestamp.Timestamp

func (*CommandRequest) ProtoMessage

func (*CommandRequest) ProtoMessage()

func (*CommandRequest) ProtoReflect

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

func (*CommandRequest) Reset

func (x *CommandRequest) Reset()

func (*CommandRequest) String

func (x *CommandRequest) String() string

type CommandResponse

type CommandResponse struct {
	Timestamp  *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Successful bool                 `protobuf:"varint,2,opt,name=successful,proto3" json:"successful,omitempty"`
	Output     []byte               `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
	ExitCode   int32                `protobuf:"varint,4,opt,name=exitCode,proto3" json:"exitCode,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandResponse) Descriptor deprecated

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

Deprecated: Use CommandResponse.ProtoReflect.Descriptor instead.

func (*CommandResponse) GetExitCode

func (x *CommandResponse) GetExitCode() int32

func (*CommandResponse) GetOutput

func (x *CommandResponse) GetOutput() []byte

func (*CommandResponse) GetSuccessful

func (x *CommandResponse) GetSuccessful() bool

func (*CommandResponse) GetTimestamp

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

func (*CommandResponse) ProtoMessage

func (*CommandResponse) ProtoMessage()

func (*CommandResponse) ProtoReflect

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

func (*CommandResponse) Reset

func (x *CommandResponse) Reset()

func (*CommandResponse) String

func (x *CommandResponse) String() string

type CommandRunnerClient

type CommandRunnerClient interface {
	Command(ctx context.Context, in *CommandRequest, opts ...grpc.CallOption) (*CommandResponse, error)
}

CommandRunnerClient is the client API for CommandRunner service.

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

type CommandRunnerServer

type CommandRunnerServer interface {
	Command(context.Context, *CommandRequest) (*CommandResponse, error)
	// contains filtered or unexported methods
}

CommandRunnerServer is the server API for CommandRunner service. All implementations must embed UnimplementedCommandRunnerServer for forward compatibility

type CommanderRequest

type CommanderRequest struct {
	Pattern string `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*CommanderRequest) Descriptor deprecated

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

Deprecated: Use CommanderRequest.ProtoReflect.Descriptor instead.

func (*CommanderRequest) GetCommand

func (x *CommanderRequest) GetCommand() string

func (*CommanderRequest) GetPattern

func (x *CommanderRequest) GetPattern() string

func (*CommanderRequest) ProtoMessage

func (*CommanderRequest) ProtoMessage()

func (*CommanderRequest) ProtoReflect

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

func (*CommanderRequest) Reset

func (x *CommanderRequest) Reset()

func (*CommanderRequest) String

func (x *CommanderRequest) String() string

type Key

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

func (*Key) Descriptor deprecated

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

Deprecated: Use Key.ProtoReflect.Descriptor instead.

func (*Key) GetKey

func (x *Key) GetKey() string

func (*Key) ProtoMessage

func (*Key) ProtoMessage()

func (*Key) ProtoReflect

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

func (*Key) Reset

func (x *Key) Reset()

func (*Key) String

func (x *Key) String() string

type NodeQuery

type NodeQuery struct {
	Pattern string `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Key     *Key   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeQuery) Descriptor deprecated

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

Deprecated: Use NodeQuery.ProtoReflect.Descriptor instead.

func (*NodeQuery) GetKey

func (x *NodeQuery) GetKey() *Key

func (*NodeQuery) GetPattern

func (x *NodeQuery) GetPattern() string

func (*NodeQuery) ProtoMessage

func (*NodeQuery) ProtoMessage()

func (*NodeQuery) ProtoReflect

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

func (*NodeQuery) Reset

func (x *NodeQuery) Reset()

func (*NodeQuery) String

func (x *NodeQuery) String() string

type NodeQueryResponse

type NodeQueryResponse struct {
	Nodes []string `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeQueryResponse) Descriptor deprecated

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

Deprecated: Use NodeQueryResponse.ProtoReflect.Descriptor instead.

func (*NodeQueryResponse) GetNodes

func (x *NodeQueryResponse) GetNodes() []string

func (*NodeQueryResponse) ProtoMessage

func (*NodeQueryResponse) ProtoMessage()

func (*NodeQueryResponse) ProtoReflect

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

func (*NodeQueryResponse) Reset

func (x *NodeQueryResponse) Reset()

func (*NodeQueryResponse) String

func (x *NodeQueryResponse) String() string

type NodeRegistrationRequest

type NodeRegistrationRequest struct {
	Info       *SysInfo   `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Key        *Key       `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	SystemType SystemType `protobuf:"varint,3,opt,name=systemType,proto3,enum=tailsys.SystemType" json:"systemType,omitempty"`
	Accepted   bool       `protobuf:"varint,4,opt,name=accepted,proto3" json:"accepted,omitempty"`
	Tlskey     string     `protobuf:"bytes,5,opt,name=tlskey,proto3" json:"tlskey,omitempty"`
	Tlscert    string     `protobuf:"bytes,6,opt,name=tlscert,proto3" json:"tlscert,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeRegistrationRequest) Descriptor deprecated

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

Deprecated: Use NodeRegistrationRequest.ProtoReflect.Descriptor instead.

func (*NodeRegistrationRequest) GetAccepted

func (x *NodeRegistrationRequest) GetAccepted() bool

func (*NodeRegistrationRequest) GetInfo

func (x *NodeRegistrationRequest) GetInfo() *SysInfo

func (*NodeRegistrationRequest) GetKey

func (x *NodeRegistrationRequest) GetKey() *Key

func (*NodeRegistrationRequest) GetSystemType

func (x *NodeRegistrationRequest) GetSystemType() SystemType

func (*NodeRegistrationRequest) GetTlscert

func (x *NodeRegistrationRequest) GetTlscert() string

func (*NodeRegistrationRequest) GetTlskey

func (x *NodeRegistrationRequest) GetTlskey() string

func (*NodeRegistrationRequest) ProtoMessage

func (*NodeRegistrationRequest) ProtoMessage()

func (*NodeRegistrationRequest) ProtoReflect

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

func (*NodeRegistrationRequest) Reset

func (x *NodeRegistrationRequest) Reset()

func (*NodeRegistrationRequest) String

func (x *NodeRegistrationRequest) String() string

type NodeRegistrationResponse

type NodeRegistrationResponse struct {
	Accepted bool   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	Key      *Key   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeRegistrationResponse) Descriptor deprecated

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

Deprecated: Use NodeRegistrationResponse.ProtoReflect.Descriptor instead.

func (*NodeRegistrationResponse) GetAccepted

func (x *NodeRegistrationResponse) GetAccepted() bool

func (*NodeRegistrationResponse) GetHostname

func (x *NodeRegistrationResponse) GetHostname() string

func (*NodeRegistrationResponse) GetKey

func (x *NodeRegistrationResponse) GetKey() *Key

func (*NodeRegistrationResponse) ProtoMessage

func (*NodeRegistrationResponse) ProtoMessage()

func (*NodeRegistrationResponse) ProtoReflect

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

func (*NodeRegistrationResponse) Reset

func (x *NodeRegistrationResponse) Reset()

func (*NodeRegistrationResponse) String

func (x *NodeRegistrationResponse) String() string

type OSType

type OSType int32
const (
	OSType_OS_TYPE_UNSPECIFIED OSType = 0
	OSType_LINUX               OSType = 1
	OSType_MACOS               OSType = 2
	OSType_WINDOWS             OSType = 3
)

func (OSType) Descriptor

func (OSType) Descriptor() protoreflect.EnumDescriptor

func (OSType) Enum

func (x OSType) Enum() *OSType

func (OSType) EnumDescriptor deprecated

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

Deprecated: Use OSType.Descriptor instead.

func (OSType) Number

func (x OSType) Number() protoreflect.EnumNumber

func (OSType) String

func (x OSType) String() string

func (OSType) Type

func (OSType) Type() protoreflect.EnumType

type PingRequest

type PingRequest struct {
	Ping *timestamp.Timestamp `protobuf:"bytes,1,opt,name=ping,proto3" json:"ping,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRequest) Descriptor deprecated

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetPing

func (x *PingRequest) GetPing() *timestamp.Timestamp

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

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

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PingerClient

type PingerClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PongResponse, error)
}

PingerClient is the client API for Pinger service.

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

func NewPingerClient

func NewPingerClient(cc grpc.ClientConnInterface) PingerClient

type PingerServer

type PingerServer interface {
	Ping(context.Context, *PingRequest) (*PongResponse, error)
	// contains filtered or unexported methods
}

PingerServer is the server API for Pinger service. All implementations must embed UnimplementedPingerServer for forward compatibility

type PongResponse

type PongResponse struct {
	Ping           *timestamp.Timestamp `protobuf:"bytes,1,opt,name=ping,proto3" json:"ping,omitempty"`
	InboundLatency float32              `protobuf:"fixed32,2,opt,name=inboundLatency,proto3" json:"inboundLatency,omitempty"`
	Key            *Key                 `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*PongResponse) Descriptor deprecated

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

Deprecated: Use PongResponse.ProtoReflect.Descriptor instead.

func (*PongResponse) GetInboundLatency

func (x *PongResponse) GetInboundLatency() float32

func (*PongResponse) GetKey

func (x *PongResponse) GetKey() *Key

func (*PongResponse) GetPing

func (x *PongResponse) GetPing() *timestamp.Timestamp

func (*PongResponse) ProtoMessage

func (*PongResponse) ProtoMessage()

func (*PongResponse) ProtoReflect

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

func (*PongResponse) Reset

func (x *PongResponse) Reset()

func (*PongResponse) String

func (x *PongResponse) String() string

type RegistrationClient

type RegistrationClient interface {
	Register(ctx context.Context, in *NodeRegistrationRequest, opts ...grpc.CallOption) (*NodeRegistrationResponse, error)
}

RegistrationClient is the client API for Registration service.

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

type RegistrationServer

type RegistrationServer interface {
	Register(context.Context, *NodeRegistrationRequest) (*NodeRegistrationResponse, error)
	// contains filtered or unexported methods
}

RegistrationServer is the server API for Registration service. All implementations must embed UnimplementedRegistrationServer for forward compatibility

type SysInfo

type SysInfo struct {
	Hostname string               `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Type     OSType               `protobuf:"varint,2,opt,name=type,proto3,enum=tailsys.OSType" json:"type,omitempty"`
	Ip       string               `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	LastSeen *timestamp.Timestamp `protobuf:"bytes,4,opt,name=lastSeen,proto3" json:"lastSeen,omitempty"`
	Port     string               `protobuf:"bytes,5,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*SysInfo) Descriptor deprecated

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

Deprecated: Use SysInfo.ProtoReflect.Descriptor instead.

func (*SysInfo) GetHostname

func (x *SysInfo) GetHostname() string

func (*SysInfo) GetIp

func (x *SysInfo) GetIp() string

func (*SysInfo) GetLastSeen

func (x *SysInfo) GetLastSeen() *timestamp.Timestamp

func (*SysInfo) GetPort

func (x *SysInfo) GetPort() string

func (*SysInfo) GetType

func (x *SysInfo) GetType() OSType

func (*SysInfo) ProtoMessage

func (*SysInfo) ProtoMessage()

func (*SysInfo) ProtoReflect

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

func (*SysInfo) Reset

func (x *SysInfo) Reset()

func (*SysInfo) String

func (x *SysInfo) String() string

type SystemType

type SystemType int32
const (
	SystemType_COORDINATION_SERVER SystemType = 0
	SystemType_CLIENT              SystemType = 1
	SystemType_CLI                 SystemType = 2
)

func (SystemType) Descriptor

func (SystemType) Descriptor() protoreflect.EnumDescriptor

func (SystemType) Enum

func (x SystemType) Enum() *SystemType

func (SystemType) EnumDescriptor deprecated

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

Deprecated: Use SystemType.Descriptor instead.

func (SystemType) Number

func (x SystemType) Number() protoreflect.EnumNumber

func (SystemType) String

func (x SystemType) String() string

func (SystemType) Type

type UnimplementedCommandManagerServer

type UnimplementedCommandManagerServer struct {
}

UnimplementedCommandManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedCommandManagerServer) GetNodes

func (UnimplementedCommandManagerServer) SendCommandToNodes

type UnimplementedCommandRunnerServer

type UnimplementedCommandRunnerServer struct {
}

UnimplementedCommandRunnerServer must be embedded to have forward compatible implementations.

func (UnimplementedCommandRunnerServer) Command

type UnimplementedPingerServer

type UnimplementedPingerServer struct {
}

UnimplementedPingerServer must be embedded to have forward compatible implementations.

func (UnimplementedPingerServer) Ping

type UnimplementedRegistrationServer

type UnimplementedRegistrationServer struct {
}

UnimplementedRegistrationServer must be embedded to have forward compatible implementations.

type UnsafeCommandManagerServer

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

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

type UnsafeCommandRunnerServer

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

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

type UnsafePingerServer

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

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

type UnsafeRegistrationServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL