service

Documentation

Index

• func CancelTasks(id uint32) error
• func Close() error
• func CloseTaskGroup(id uint32) error
• func GetTaskOutput(id int64) ([]byte, error)
• func HelloHandshake(ctx context.Context) error
• func HelloInit(ctx context.Context) (grpc.ServerStreamingClient[operatorv1.HelloResponse], error)
• func HelloMonitor(ctx context.Context) error
• func Init(ctx context.Context, host string, token string) error
• func NewTask(id uint32, v *operatorv1.NewTaskRequest) error
• func NewTaskGroup(id uint32, cmd string, visible bool) error
• func NewTaskGroupMessage(id uint32, tm defaults.TaskMessage, message string) error
• func PollBeaconTasks(b *beacon.Beacon) error
• func SendChatMessage(message string) error
• func SubscribeBeacons(ctx context.Context) error
• func SubscribeChat(ctx context.Context) error
• func SubscribeTasks(ctx context.Context) error
• func UnpollBeaconTasks(b *beacon.Beacon) error

Functions

func CancelTasks

func CancelTasks(id uint32) error

отмена всех тасок, поставленных оператором

func Close

func Close() error

func CloseTaskGroup

func CloseTaskGroup(id uint32) error

закрытие таск группы

func GetTaskOutput

func GetTaskOutput(id int64) ([]byte, error)

получение output'a таска

func HelloHandshake

func HelloHandshake(ctx context.Context) error

обработка хендшейка из control стрима

func HelloInit

func HelloInit(ctx context.Context) (grpc.ServerStreamingClient[operatorv1.HelloResponse], error)

первичное подключение оператора к control стриму

func HelloMonitor

func HelloMonitor(ctx context.Context) error

поддержание подписки на control стрим

func Init

func Init(ctx context.Context, host string, token string) error

инициализация подключения к mgmt серверу

func NewTask

func NewTask(id uint32, v *operatorv1.NewTaskRequest) error

создание нового таска

func NewTaskGroup

func NewTaskGroup(id uint32, cmd string, visible bool) error

открытие новой таск группы

func NewTaskGroupMessage

func NewTaskGroupMessage(id uint32, tm defaults.TaskMessage, message string) error

отправка сообщения в таск группу

func PollBeaconTasks

func PollBeaconTasks(b *beacon.Beacon) error

подписка на получение тасков для определенного бикона

func SendChatMessage

func SendChatMessage(message string) error

создание сообщения в чат

func SubscribeBeacons

func SubscribeBeacons(ctx context.Context) error

подписка на получение биконов

func SubscribeChat

func SubscribeChat(ctx context.Context) error

подписка на получение сообщений из чата

func SubscribeTasks

func SubscribeTasks(ctx context.Context) error

подписка на получение обновлений по таскам

func UnpollBeaconTasks

func UnpollBeaconTasks(b *beacon.Beacon) error

стоп подписки на получение тасков для определенного бикона