proto

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ConsoleService_ListMinions_FullMethodName       = "/minexus.ConsoleService/ListMinions"
	ConsoleService_ListTags_FullMethodName          = "/minexus.ConsoleService/ListTags"
	ConsoleService_SetTags_FullMethodName           = "/minexus.ConsoleService/SetTags"
	ConsoleService_UpdateTags_FullMethodName        = "/minexus.ConsoleService/UpdateTags"
	ConsoleService_SendCommand_FullMethodName       = "/minexus.ConsoleService/SendCommand"
	ConsoleService_GetCommandResults_FullMethodName = "/minexus.ConsoleService/GetCommandResults"
	ConsoleService_GetCommandStatus_FullMethodName  = "/minexus.ConsoleService/GetCommandStatus"
)
View Source 
const (
	MinionService_Register_FullMethodName       = "/minexus.MinionService/Register"
	MinionService_StreamCommands_FullMethodName = "/minexus.MinionService/StreamCommands"
)

Variables

View Source 
var (
	CommandType_name = map[int32]string{
		0: "SYSTEM",
		1: "INTERNAL",
	}
	CommandType_value = map[string]int32{
		"SYSTEM":   0,
		"INTERNAL": 1,
	}
)

Enum value maps for CommandType.

View Source 
var ConsoleService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "minexus.ConsoleService",
	HandlerType: (*ConsoleServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListMinions",
			Handler:    _ConsoleService_ListMinions_Handler,
		},
		{
			MethodName: "ListTags",
			Handler:    _ConsoleService_ListTags_Handler,
		},
		{
			MethodName: "SetTags",
			Handler:    _ConsoleService_SetTags_Handler,
		},
		{
			MethodName: "UpdateTags",
			Handler:    _ConsoleService_UpdateTags_Handler,
		},
		{
			MethodName: "SendCommand",
			Handler:    _ConsoleService_SendCommand_Handler,
		},
		{
			MethodName: "GetCommandResults",
			Handler:    _ConsoleService_GetCommandResults_Handler,
		},
		{
			MethodName: "GetCommandStatus",
			Handler:    _ConsoleService_GetCommandStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "minexus.proto",
}

ConsoleService_ServiceDesc is the grpc.ServiceDesc for ConsoleService 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_minexus_proto protoreflect.FileDescriptor
View Source 
var MinionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "minexus.MinionService",
	HandlerType: (*MinionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _MinionService_Register_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamCommands",
			Handler:       _MinionService_StreamCommands_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "minexus.proto",
}

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

Functions

func RegisterConsoleServiceServer 

func RegisterConsoleServiceServer(s grpc.ServiceRegistrar, srv ConsoleServiceServer)

func RegisterMinionServiceServer 

func RegisterMinionServiceServer(s grpc.ServiceRegistrar, srv MinionServiceServer)

Types

type Ack 

type Ack struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*Ack) Descriptor deprecated 

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetSuccess 

func (x *Ack) GetSuccess() bool

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect 

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

func (*Ack) Reset 

func (x *Ack) Reset()

func (*Ack) String 

func (x *Ack) String() string

type Command 

type Command struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type     CommandType       `protobuf:"varint,2,opt,name=type,proto3,enum=minexus.CommandType" json:"type,omitempty"`
	Payload  string            `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Metadata map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetId 

func (x *Command) GetId() string

func (*Command) GetMetadata 

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

func (*Command) GetPayload 

func (x *Command) GetPayload() string

func (*Command) GetType 

func (x *Command) GetType() CommandType

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

type CommandDispatchResponse 

type CommandDispatchResponse struct {
	Accepted  bool   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	CommandId string `protobuf:"bytes,2,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandDispatchResponse) Descriptor deprecated 

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

Deprecated: Use CommandDispatchResponse.ProtoReflect.Descriptor instead.

func (*CommandDispatchResponse) GetAccepted 

func (x *CommandDispatchResponse) GetAccepted() bool

func (*CommandDispatchResponse) GetCommandId 

func (x *CommandDispatchResponse) GetCommandId() string

func (*CommandDispatchResponse) ProtoMessage 

func (*CommandDispatchResponse) ProtoMessage()

func (*CommandDispatchResponse) ProtoReflect 

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

func (*CommandDispatchResponse) Reset 

func (x *CommandDispatchResponse) Reset()

func (*CommandDispatchResponse) String 

func (x *CommandDispatchResponse) String() string

type CommandRequest 

type CommandRequest struct {
	MinionIds   []string     `protobuf:"bytes,1,rep,name=minion_ids,json=minionIds,proto3" json:"minion_ids,omitempty"`
	TagSelector *TagSelector `protobuf:"bytes,2,opt,name=tag_selector,json=tagSelector,proto3" json:"tag_selector,omitempty"`
	Command     *Command     `protobuf:"bytes,3,opt,name=command,proto3" json:"command,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() *Command

func (*CommandRequest) GetMinionIds 

func (x *CommandRequest) GetMinionIds() []string

func (*CommandRequest) GetTagSelector 

func (x *CommandRequest) GetTagSelector() *TagSelector

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 CommandResult 

type CommandResult struct {
	CommandId string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	MinionId  string `protobuf:"bytes,2,opt,name=minion_id,json=minionId,proto3" json:"minion_id,omitempty"`
	ExitCode  int32  `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Stdout    string `protobuf:"bytes,4,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr    string `protobuf:"bytes,5,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Timestamp int64  `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandResult) Descriptor deprecated 

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

Deprecated: Use CommandResult.ProtoReflect.Descriptor instead.

func (*CommandResult) GetCommandId 

func (x *CommandResult) GetCommandId() string

func (*CommandResult) GetExitCode 

func (x *CommandResult) GetExitCode() int32

func (*CommandResult) GetMinionId 

func (x *CommandResult) GetMinionId() string

func (*CommandResult) GetStderr 

func (x *CommandResult) GetStderr() string

func (*CommandResult) GetStdout 

func (x *CommandResult) GetStdout() string

func (*CommandResult) GetTimestamp 

func (x *CommandResult) GetTimestamp() int64

func (*CommandResult) ProtoMessage 

func (*CommandResult) ProtoMessage()

func (*CommandResult) ProtoReflect 

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

func (*CommandResult) Reset 

func (x *CommandResult) Reset()

func (*CommandResult) String 

func (x *CommandResult) String() string

type CommandResults 

type CommandResults struct {
	Results []*CommandResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandResults) Descriptor deprecated 

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

Deprecated: Use CommandResults.ProtoReflect.Descriptor instead.

func (*CommandResults) GetResults 

func (x *CommandResults) GetResults() []*CommandResult

func (*CommandResults) ProtoMessage 

func (*CommandResults) ProtoMessage()

func (*CommandResults) ProtoReflect 

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

func (*CommandResults) Reset 

func (x *CommandResults) Reset()

func (*CommandResults) String 

func (x *CommandResults) String() string

type CommandStatusResponse 

type CommandStatusResponse struct {
	CommandId    string                                `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	Statuses     []*CommandStatusResponse_MinionStatus `protobuf:"bytes,2,rep,name=statuses,proto3" json:"statuses,omitempty"`
	StatusCounts map[string]int32                      `` // Count of minions in each status
	/* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CommandStatusResponse) Descriptor deprecated 

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

Deprecated: Use CommandStatusResponse.ProtoReflect.Descriptor instead.

func (*CommandStatusResponse) GetCommandId 

func (x *CommandStatusResponse) GetCommandId() string

func (*CommandStatusResponse) GetStatusCounts 

func (x *CommandStatusResponse) GetStatusCounts() map[string]int32

func (*CommandStatusResponse) GetStatuses 

func (x *CommandStatusResponse) GetStatuses() []*CommandStatusResponse_MinionStatus

func (*CommandStatusResponse) ProtoMessage 

func (*CommandStatusResponse) ProtoMessage()

func (*CommandStatusResponse) ProtoReflect 

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

func (*CommandStatusResponse) Reset 

func (x *CommandStatusResponse) Reset()

func (*CommandStatusResponse) String 

func (x *CommandStatusResponse) String() string

type CommandStatusResponse_MinionStatus 

type CommandStatusResponse_MinionStatus struct {
	MinionId  string `protobuf:"bytes,1,opt,name=minion_id,json=minionId,proto3" json:"minion_id,omitempty"`
	Status    string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // "PENDING", "RECEIVED", "EXECUTING", "COMPLETED", "FAILED"
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandStatusResponse_MinionStatus) Descriptor deprecated 

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

Deprecated: Use CommandStatusResponse_MinionStatus.ProtoReflect.Descriptor instead.

func (*CommandStatusResponse_MinionStatus) GetMinionId 

func (x *CommandStatusResponse_MinionStatus) GetMinionId() string

func (*CommandStatusResponse_MinionStatus) GetStatus 

func (x *CommandStatusResponse_MinionStatus) GetStatus() string

func (*CommandStatusResponse_MinionStatus) GetTimestamp 

func (x *CommandStatusResponse_MinionStatus) GetTimestamp() int64

func (*CommandStatusResponse_MinionStatus) ProtoMessage 

func (*CommandStatusResponse_MinionStatus) ProtoMessage()

func (*CommandStatusResponse_MinionStatus) ProtoReflect 

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

func (*CommandStatusResponse_MinionStatus) Reset 

func (x *CommandStatusResponse_MinionStatus) Reset()

func (*CommandStatusResponse_MinionStatus) String 

func (x *CommandStatusResponse_MinionStatus) String() string

type CommandStatusUpdate 

type CommandStatusUpdate struct {
	CommandId string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	MinionId  string `protobuf:"bytes,2,opt,name=minion_id,json=minionId,proto3" json:"minion_id,omitempty"`
	Status    string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` // "RECEIVED", "EXECUTING", "COMPLETED", "FAILED"
	Timestamp int64  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

New message for command status updates

func (*CommandStatusUpdate) Descriptor deprecated 

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

Deprecated: Use CommandStatusUpdate.ProtoReflect.Descriptor instead.

func (*CommandStatusUpdate) GetCommandId 

func (x *CommandStatusUpdate) GetCommandId() string

func (*CommandStatusUpdate) GetMinionId 

func (x *CommandStatusUpdate) GetMinionId() string

func (*CommandStatusUpdate) GetStatus 

func (x *CommandStatusUpdate) GetStatus() string

func (*CommandStatusUpdate) GetTimestamp 

func (x *CommandStatusUpdate) GetTimestamp() int64

func (*CommandStatusUpdate) ProtoMessage 

func (*CommandStatusUpdate) ProtoMessage()

func (*CommandStatusUpdate) ProtoReflect 

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

func (*CommandStatusUpdate) Reset 

func (x *CommandStatusUpdate) Reset()

func (*CommandStatusUpdate) String 

func (x *CommandStatusUpdate) String() string

type CommandStreamMessage 

type CommandStreamMessage struct {

	// Types that are valid to be assigned to Message:
	//
	//	*CommandStreamMessage_Command
	//	*CommandStreamMessage_Result
	//	*CommandStreamMessage_Status
	Message isCommandStreamMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*CommandStreamMessage) Descriptor deprecated 

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

Deprecated: Use CommandStreamMessage.ProtoReflect.Descriptor instead.

func (*CommandStreamMessage) GetCommand 

func (x *CommandStreamMessage) GetCommand() *Command

func (*CommandStreamMessage) GetMessage 

func (x *CommandStreamMessage) GetMessage() isCommandStreamMessage_Message

func (*CommandStreamMessage) GetResult 

func (x *CommandStreamMessage) GetResult() *CommandResult

func (*CommandStreamMessage) GetStatus 

func (x *CommandStreamMessage) GetStatus() *CommandStatusUpdate

func (*CommandStreamMessage) ProtoMessage 

func (*CommandStreamMessage) ProtoMessage()

func (*CommandStreamMessage) ProtoReflect 

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

func (*CommandStreamMessage) Reset 

func (x *CommandStreamMessage) Reset()

func (*CommandStreamMessage) String 

func (x *CommandStreamMessage) String() string

type CommandStreamMessage_Command 

type CommandStreamMessage_Command struct {
	Command *Command `protobuf:"bytes,1,opt,name=command,proto3,oneof"` // Nexus -> Minion: New command to execute
}

type CommandStreamMessage_Result 

type CommandStreamMessage_Result struct {
	Result *CommandResult `protobuf:"bytes,2,opt,name=result,proto3,oneof"` // Minion -> Nexus: Result of executed command
}

type CommandStreamMessage_Status 

type CommandStreamMessage_Status struct {
	Status *CommandStatusUpdate `protobuf:"bytes,3,opt,name=status,proto3,oneof"` // Minion -> Nexus: Status update for command
}

type CommandType 

type CommandType int32
const (
	CommandType_SYSTEM   CommandType = 0
	CommandType_INTERNAL CommandType = 1
)

func (CommandType) Descriptor 

func (CommandType) Descriptor() protoreflect.EnumDescriptor

func (CommandType) Enum 

func (x CommandType) Enum() *CommandType

func (CommandType) EnumDescriptor deprecated 

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

Deprecated: Use CommandType.Descriptor instead.

func (CommandType) Number 

func (x CommandType) Number() protoreflect.EnumNumber

func (CommandType) String 

func (x CommandType) String() string

func (CommandType) Type 

func (CommandType) Type() protoreflect.EnumType

type ConsoleServiceClient 

type ConsoleServiceClient interface {
	ListMinions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*MinionList, error)
	ListTags(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TagList, error)
	SetTags(ctx context.Context, in *SetTagsRequest, opts ...grpc.CallOption) (*Ack, error)
	UpdateTags(ctx context.Context, in *UpdateTagsRequest, opts ...grpc.CallOption) (*Ack, error)
	SendCommand(ctx context.Context, in *CommandRequest, opts ...grpc.CallOption) (*CommandDispatchResponse, error)
	GetCommandResults(ctx context.Context, in *ResultRequest, opts ...grpc.CallOption) (*CommandResults, error)
	GetCommandStatus(ctx context.Context, in *ResultRequest, opts ...grpc.CallOption) (*CommandStatusResponse, error)
}

ConsoleServiceClient is the client API for ConsoleService 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 NewConsoleServiceClient 

func NewConsoleServiceClient(cc grpc.ClientConnInterface) ConsoleServiceClient

type ConsoleServiceServer 

type ConsoleServiceServer interface {
	ListMinions(context.Context, *Empty) (*MinionList, error)
	ListTags(context.Context, *Empty) (*TagList, error)
	SetTags(context.Context, *SetTagsRequest) (*Ack, error)
	UpdateTags(context.Context, *UpdateTagsRequest) (*Ack, error)
	SendCommand(context.Context, *CommandRequest) (*CommandDispatchResponse, error)
	GetCommandResults(context.Context, *ResultRequest) (*CommandResults, error)
	GetCommandStatus(context.Context, *ResultRequest) (*CommandStatusResponse, error)
	// contains filtered or unexported methods
}

ConsoleServiceServer is the server API for ConsoleService service. All implementations must embed UnimplementedConsoleServiceServer for forward compatibility.

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type HostInfo 

type HostInfo struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hostname string            `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Ip       string            `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	Os       string            `protobuf:"bytes,4,opt,name=os,proto3" json:"os,omitempty"`
	Tags     map[string]string ``                                                                                       /* 135-byte string literal not displayed */
	LastSeen int64             `protobuf:"varint,6,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"` // Unix timestamp of last registration/communication
	// contains filtered or unexported fields
}

func (*HostInfo) Descriptor deprecated 

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

Deprecated: Use HostInfo.ProtoReflect.Descriptor instead.

func (*HostInfo) GetHostname 

func (x *HostInfo) GetHostname() string

func (*HostInfo) GetId 

func (x *HostInfo) GetId() string

func (*HostInfo) GetIp 

func (x *HostInfo) GetIp() string

func (*HostInfo) GetLastSeen 

func (x *HostInfo) GetLastSeen() int64

func (*HostInfo) GetOs 

func (x *HostInfo) GetOs() string

func (*HostInfo) GetTags 

func (x *HostInfo) GetTags() map[string]string

func (*HostInfo) ProtoMessage 

func (*HostInfo) ProtoMessage()

func (*HostInfo) ProtoReflect 

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

func (*HostInfo) Reset 

func (x *HostInfo) Reset()

func (*HostInfo) String 

func (x *HostInfo) String() string

type MinionInfo 

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

func (*MinionInfo) Descriptor deprecated 

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

Deprecated: Use MinionInfo.ProtoReflect.Descriptor instead.

func (*MinionInfo) GetId 

func (x *MinionInfo) GetId() string

func (*MinionInfo) ProtoMessage 

func (*MinionInfo) ProtoMessage()

func (*MinionInfo) ProtoReflect 

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

func (*MinionInfo) Reset 

func (x *MinionInfo) Reset()

func (*MinionInfo) String 

func (x *MinionInfo) String() string

type MinionList 

type MinionList struct {
	Minions []*HostInfo `protobuf:"bytes,1,rep,name=minions,proto3" json:"minions,omitempty"`
	// contains filtered or unexported fields
}

func (*MinionList) Descriptor deprecated 

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

Deprecated: Use MinionList.ProtoReflect.Descriptor instead.

func (*MinionList) GetMinions 

func (x *MinionList) GetMinions() []*HostInfo

func (*MinionList) ProtoMessage 

func (*MinionList) ProtoMessage()

func (*MinionList) ProtoReflect 

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

func (*MinionList) Reset 

func (x *MinionList) Reset()

func (*MinionList) String 

func (x *MinionList) String() string

type MinionServiceClient 

type MinionServiceClient interface {
	Register(ctx context.Context, in *HostInfo, opts ...grpc.CallOption) (*RegisterResponse, error)
	StreamCommands(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[CommandStreamMessage, CommandStreamMessage], error)
}

MinionServiceClient is the client API for MinionService 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 NewMinionServiceClient 

func NewMinionServiceClient(cc grpc.ClientConnInterface) MinionServiceClient

type MinionServiceServer 

type MinionServiceServer interface {
	Register(context.Context, *HostInfo) (*RegisterResponse, error)
	StreamCommands(grpc.BidiStreamingServer[CommandStreamMessage, CommandStreamMessage]) error
	// contains filtered or unexported methods
}

MinionServiceServer is the server API for MinionService service. All implementations must embed UnimplementedMinionServiceServer for forward compatibility.

type MinionService_StreamCommandsClient 

type MinionService_StreamCommandsClient = grpc.BidiStreamingClient[CommandStreamMessage, CommandStreamMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type MinionService_StreamCommandsServer 

type MinionService_StreamCommandsServer = grpc.BidiStreamingServer[CommandStreamMessage, CommandStreamMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type RegisterResponse 

type RegisterResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	AssignedId   string `protobuf:"bytes,2,opt,name=assigned_id,json=assignedId,proto3" json:"assigned_id,omitempty"`
	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponse) Descriptor deprecated 

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetAssignedId 

func (x *RegisterResponse) GetAssignedId() string

func (*RegisterResponse) GetErrorMessage 

func (x *RegisterResponse) GetErrorMessage() string

func (*RegisterResponse) GetSuccess 

func (x *RegisterResponse) GetSuccess() bool

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect 

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

func (*RegisterResponse) Reset 

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (x *RegisterResponse) String() string

type ResultRequest 

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

func (*ResultRequest) Descriptor deprecated 

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

Deprecated: Use ResultRequest.ProtoReflect.Descriptor instead.

func (*ResultRequest) GetCommandId 

func (x *ResultRequest) GetCommandId() string

func (*ResultRequest) ProtoMessage 

func (*ResultRequest) ProtoMessage()

func (*ResultRequest) ProtoReflect 

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

func (*ResultRequest) Reset 

func (x *ResultRequest) Reset()

func (*ResultRequest) String 

func (x *ResultRequest) String() string

type SetTagsRequest 

type SetTagsRequest struct {
	MinionId string            `protobuf:"bytes,1,opt,name=minion_id,json=minionId,proto3" json:"minion_id,omitempty"`
	Tags     map[string]string `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetTagsRequest) Descriptor deprecated 

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

Deprecated: Use SetTagsRequest.ProtoReflect.Descriptor instead.

func (*SetTagsRequest) GetMinionId 

func (x *SetTagsRequest) GetMinionId() string

func (*SetTagsRequest) GetTags 

func (x *SetTagsRequest) GetTags() map[string]string

func (*SetTagsRequest) ProtoMessage 

func (*SetTagsRequest) ProtoMessage()

func (*SetTagsRequest) ProtoReflect 

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

func (*SetTagsRequest) Reset 

func (x *SetTagsRequest) Reset()

func (*SetTagsRequest) String 

func (x *SetTagsRequest) String() string

type TagList 

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

func (*TagList) Descriptor deprecated 

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

Deprecated: Use TagList.ProtoReflect.Descriptor instead.

func (*TagList) GetTags 

func (x *TagList) GetTags() []string

func (*TagList) ProtoMessage 

func (*TagList) ProtoMessage()

func (*TagList) ProtoReflect 

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

func (*TagList) Reset 

func (x *TagList) Reset()

func (*TagList) String 

func (x *TagList) String() string

type TagMatch 

type TagMatch struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are valid to be assigned to Condition:
	//
	//	*TagMatch_Equals
	//	*TagMatch_Exists
	//	*TagMatch_NotExists
	Condition isTagMatch_Condition `protobuf_oneof:"condition"`
	// contains filtered or unexported fields
}

func (*TagMatch) Descriptor deprecated 

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

Deprecated: Use TagMatch.ProtoReflect.Descriptor instead.

func (*TagMatch) GetCondition 

func (x *TagMatch) GetCondition() isTagMatch_Condition

func (*TagMatch) GetEquals 

func (x *TagMatch) GetEquals() string

func (*TagMatch) GetExists 

func (x *TagMatch) GetExists() bool

func (*TagMatch) GetKey 

func (x *TagMatch) GetKey() string

func (*TagMatch) GetNotExists 

func (x *TagMatch) GetNotExists() bool

func (*TagMatch) ProtoMessage 

func (*TagMatch) ProtoMessage()

func (*TagMatch) ProtoReflect 

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

func (*TagMatch) Reset 

func (x *TagMatch) Reset()

func (*TagMatch) String 

func (x *TagMatch) String() string

type TagMatch_Equals 

type TagMatch_Equals struct {
	Equals string `protobuf:"bytes,2,opt,name=equals,proto3,oneof"`
}

type TagMatch_Exists 

type TagMatch_Exists struct {
	Exists bool `protobuf:"varint,3,opt,name=exists,proto3,oneof"`
}

type TagMatch_NotExists 

type TagMatch_NotExists struct {
	NotExists bool `protobuf:"varint,4,opt,name=not_exists,json=notExists,proto3,oneof"`
}

type TagSelector 

type TagSelector struct {
	Rules []*TagMatch `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"` // AND logique
	// contains filtered or unexported fields
}

func (*TagSelector) Descriptor deprecated 

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

Deprecated: Use TagSelector.ProtoReflect.Descriptor instead.

func (*TagSelector) GetRules 

func (x *TagSelector) GetRules() []*TagMatch

func (*TagSelector) ProtoMessage 

func (*TagSelector) ProtoMessage()

func (*TagSelector) ProtoReflect 

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

func (*TagSelector) Reset 

func (x *TagSelector) Reset()

func (*TagSelector) String 

func (x *TagSelector) String() string

type UnimplementedConsoleServiceServer 

type UnimplementedConsoleServiceServer struct{}

UnimplementedConsoleServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedConsoleServiceServer) GetCommandResults 

func (UnimplementedConsoleServiceServer) GetCommandResults(context.Context, *ResultRequest) (*CommandResults, error)

func (UnimplementedConsoleServiceServer) GetCommandStatus 

func (UnimplementedConsoleServiceServer) GetCommandStatus(context.Context, *ResultRequest) (*CommandStatusResponse, error)

func (UnimplementedConsoleServiceServer) ListMinions 

func (UnimplementedConsoleServiceServer) ListMinions(context.Context, *Empty) (*MinionList, error)

func (UnimplementedConsoleServiceServer) ListTags 

func (UnimplementedConsoleServiceServer) ListTags(context.Context, *Empty) (*TagList, error)

func (UnimplementedConsoleServiceServer) SendCommand 

func (UnimplementedConsoleServiceServer) SendCommand(context.Context, *CommandRequest) (*CommandDispatchResponse, error)

func (UnimplementedConsoleServiceServer) SetTags 

func (UnimplementedConsoleServiceServer) SetTags(context.Context, *SetTagsRequest) (*Ack, error)

func (UnimplementedConsoleServiceServer) UpdateTags 

func (UnimplementedConsoleServiceServer) UpdateTags(context.Context, *UpdateTagsRequest) (*Ack, error)

type UnimplementedMinionServiceServer 

type UnimplementedMinionServiceServer struct{}

UnimplementedMinionServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedMinionServiceServer) Register 

func (UnimplementedMinionServiceServer) Register(context.Context, *HostInfo) (*RegisterResponse, error)

func (UnimplementedMinionServiceServer) StreamCommands 

func (UnimplementedMinionServiceServer) StreamCommands(grpc.BidiStreamingServer[CommandStreamMessage, CommandStreamMessage]) error

type UnsafeConsoleServiceServer 

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

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

type UnsafeMinionServiceServer 

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

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

type UpdateTagsRequest 

type UpdateTagsRequest struct {
	MinionId   string            `protobuf:"bytes,1,opt,name=minion_id,json=minionId,proto3" json:"minion_id,omitempty"`
	Add        map[string]string `` /* 133-byte string literal not displayed */
	RemoveKeys []string          `protobuf:"bytes,3,rep,name=remove_keys,json=removeKeys,proto3" json:"remove_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTagsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTagsRequest.ProtoReflect.Descriptor instead.

func (*UpdateTagsRequest) GetAdd 

func (x *UpdateTagsRequest) GetAdd() map[string]string

func (*UpdateTagsRequest) GetMinionId 

func (x *UpdateTagsRequest) GetMinionId() string

func (*UpdateTagsRequest) GetRemoveKeys 

func (x *UpdateTagsRequest) GetRemoveKeys() []string

func (*UpdateTagsRequest) ProtoMessage 

func (*UpdateTagsRequest) ProtoMessage()

func (*UpdateTagsRequest) ProtoReflect 

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

func (*UpdateTagsRequest) Reset 

func (x *UpdateTagsRequest) Reset()

func (*UpdateTagsRequest) String 

func (x *UpdateTagsRequest) String() string

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.