Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterCommandManagerServer(s grpc.ServiceRegistrar, srv CommandManagerServer)
- func RegisterCommandRunnerServer(s grpc.ServiceRegistrar, srv CommandRunnerServer)
- func RegisterPingerServer(s grpc.ServiceRegistrar, srv PingerServer)
- func RegisterRegistrationServer(s grpc.ServiceRegistrar, srv RegistrationServer)
- type AggregateResponses
- func (*AggregateResponses) Descriptor() ([]byte, []int)deprecated
- func (x *AggregateResponses) GetResponse() []*CommandResponse
- func (*AggregateResponses) ProtoMessage()
- func (x *AggregateResponses) ProtoReflect() protoreflect.Message
- func (x *AggregateResponses) Reset()
- func (x *AggregateResponses) String() string
- type CommandManagerClient
- type CommandManagerServer
- type CommandManager_SendCommandToNodesStreamClient
- type CommandManager_SendCommandToNodesStreamServer
- type CommandRequest
- func (*CommandRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CommandRequest) GetCommand() string
- func (x *CommandRequest) GetKey() *Key
- func (x *CommandRequest) GetRequested() *timestamp.Timestamp
- func (*CommandRequest) ProtoMessage()
- func (x *CommandRequest) ProtoReflect() protoreflect.Message
- func (x *CommandRequest) Reset()
- func (x *CommandRequest) String() string
- type CommandResponse
- func (*CommandResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CommandResponse) GetExitCode() int32
- func (x *CommandResponse) GetOutput() []byte
- func (x *CommandResponse) GetSuccessful() bool
- func (x *CommandResponse) GetTimestamp() *timestamp.Timestamp
- func (*CommandResponse) ProtoMessage()
- func (x *CommandResponse) ProtoReflect() protoreflect.Message
- func (x *CommandResponse) Reset()
- func (x *CommandResponse) String() string
- type CommandRunnerClient
- type CommandRunnerServer
- type CommanderRequest
- func (*CommanderRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CommanderRequest) GetCommand() string
- func (x *CommanderRequest) GetPattern() string
- func (*CommanderRequest) ProtoMessage()
- func (x *CommanderRequest) ProtoReflect() protoreflect.Message
- func (x *CommanderRequest) Reset()
- func (x *CommanderRequest) String() string
- type Key
- type NodeQuery
- type NodeQueryResponse
- type NodeRegistrationRequest
- func (*NodeRegistrationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NodeRegistrationRequest) GetAccepted() bool
- func (x *NodeRegistrationRequest) GetInfo() *SysInfo
- func (x *NodeRegistrationRequest) GetKey() *Key
- func (x *NodeRegistrationRequest) GetSystemType() SystemType
- func (x *NodeRegistrationRequest) GetTlscert() string
- func (x *NodeRegistrationRequest) GetTlskey() string
- func (*NodeRegistrationRequest) ProtoMessage()
- func (x *NodeRegistrationRequest) ProtoReflect() protoreflect.Message
- func (x *NodeRegistrationRequest) Reset()
- func (x *NodeRegistrationRequest) String() string
- type NodeRegistrationResponse
- func (*NodeRegistrationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NodeRegistrationResponse) GetAccepted() bool
- func (x *NodeRegistrationResponse) GetHostname() string
- func (x *NodeRegistrationResponse) GetKey() *Key
- func (*NodeRegistrationResponse) ProtoMessage()
- func (x *NodeRegistrationResponse) ProtoReflect() protoreflect.Message
- func (x *NodeRegistrationResponse) Reset()
- func (x *NodeRegistrationResponse) String() string
- type OSType
- type PingRequest
- type PingerClient
- type PingerServer
- type PongResponse
- func (*PongResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PongResponse) GetInboundLatency() float32
- func (x *PongResponse) GetKey() *Key
- func (x *PongResponse) GetPing() *timestamp.Timestamp
- func (*PongResponse) ProtoMessage()
- func (x *PongResponse) ProtoReflect() protoreflect.Message
- func (x *PongResponse) Reset()
- func (x *PongResponse) String() string
- type RegistrationClient
- type RegistrationServer
- type SysInfo
- func (*SysInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SysInfo) GetHostname() string
- func (x *SysInfo) GetIp() string
- func (x *SysInfo) GetLastSeen() *timestamp.Timestamp
- func (x *SysInfo) GetPort() string
- func (x *SysInfo) GetType() OSType
- func (*SysInfo) ProtoMessage()
- func (x *SysInfo) ProtoReflect() protoreflect.Message
- func (x *SysInfo) Reset()
- func (x *SysInfo) String() string
- type SystemType
- type UnimplementedCommandManagerServer
- func (UnimplementedCommandManagerServer) GetNodes(context.Context, *NodeQuery) (*NodeQueryResponse, error)
- func (UnimplementedCommandManagerServer) SendCommandToNodes(context.Context, *CommanderRequest) (*AggregateResponses, error)
- func (UnimplementedCommandManagerServer) SendCommandToNodesStream(*CommanderRequest, CommandManager_SendCommandToNodesStreamServer) error
- type UnimplementedCommandRunnerServer
- type UnimplementedPingerServer
- type UnimplementedRegistrationServer
- type UnsafeCommandManagerServer
- type UnsafeCommandRunnerServer
- type UnsafePingerServer
- type UnsafeRegistrationServer
Constants ¶
const ( CommandManager_GetNodes_FullMethodName = "/tailsys.CommandManager/GetNodes" CommandManager_SendCommandToNodes_FullMethodName = "/tailsys.CommandManager/SendCommandToNodes" CommandManager_SendCommandToNodesStream_FullMethodName = "/tailsys.CommandManager/SendCommandToNodesStream" )
const (
CommandRunner_Command_FullMethodName = "/tailsys.CommandRunner/Command"
)
const (
Pinger_Ping_FullMethodName = "/tailsys.Pinger/Ping"
)
const (
Registration_Register_FullMethodName = "/tailsys.Registration/Register"
)
Variables ¶
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.
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.
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)
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)
var File_command_proto protoreflect.FileDescriptor
var File_sysinfo_proto protoreflect.FileDescriptor
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)
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.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewCommandManagerClient ¶
func NewCommandManagerClient(cc grpc.ClientConnInterface) CommandManagerClient
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.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewCommandRunnerClient ¶
func NewCommandRunnerClient(cc grpc.ClientConnInterface) CommandRunnerClient
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) ProtoMessage ¶
func (*Key) ProtoMessage()
func (*Key) ProtoReflect ¶
func (x *Key) ProtoReflect() protoreflect.Message
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) GetPattern ¶
func (*NodeQuery) ProtoMessage ¶
func (*NodeQuery) ProtoMessage()
func (*NodeQuery) ProtoReflect ¶
func (x *NodeQuery) ProtoReflect() protoreflect.Message
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
func (OSType) Descriptor ¶
func (OSType) Descriptor() protoreflect.EnumDescriptor
func (OSType) EnumDescriptor
deprecated
func (OSType) Number ¶
func (x OSType) Number() protoreflect.EnumNumber
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.go.dev/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.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRegistrationClient ¶
func NewRegistrationClient(cc grpc.ClientConnInterface) RegistrationClient
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) GetHostname ¶
func (*SysInfo) GetLastSeen ¶
func (*SysInfo) ProtoMessage ¶
func (*SysInfo) ProtoMessage()
func (*SysInfo) ProtoReflect ¶
func (x *SysInfo) ProtoReflect() protoreflect.Message
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 ¶
func (SystemType) Type() protoreflect.EnumType
type UnimplementedCommandManagerServer ¶
type UnimplementedCommandManagerServer struct { }
UnimplementedCommandManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedCommandManagerServer) GetNodes ¶
func (UnimplementedCommandManagerServer) GetNodes(context.Context, *NodeQuery) (*NodeQueryResponse, error)
func (UnimplementedCommandManagerServer) SendCommandToNodes ¶
func (UnimplementedCommandManagerServer) SendCommandToNodes(context.Context, *CommanderRequest) (*AggregateResponses, error)
func (UnimplementedCommandManagerServer) SendCommandToNodesStream ¶
func (UnimplementedCommandManagerServer) SendCommandToNodesStream(*CommanderRequest, CommandManager_SendCommandToNodesStreamServer) error
type UnimplementedCommandRunnerServer ¶
type UnimplementedCommandRunnerServer struct { }
UnimplementedCommandRunnerServer must be embedded to have forward compatible implementations.
func (UnimplementedCommandRunnerServer) Command ¶
func (UnimplementedCommandRunnerServer) Command(context.Context, *CommandRequest) (*CommandResponse, error)
type UnimplementedPingerServer ¶
type UnimplementedPingerServer struct { }
UnimplementedPingerServer must be embedded to have forward compatible implementations.
func (UnimplementedPingerServer) Ping ¶
func (UnimplementedPingerServer) Ping(context.Context, *PingRequest) (*PongResponse, error)
type UnimplementedRegistrationServer ¶
type UnimplementedRegistrationServer struct { }
UnimplementedRegistrationServer must be embedded to have forward compatible implementations.
func (UnimplementedRegistrationServer) Register ¶
func (UnimplementedRegistrationServer) Register(context.Context, *NodeRegistrationRequest) (*NodeRegistrationResponse, error)
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.