tasks

package
v0.0.12 Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2024 License: MIT Imports: 23 Imported by: 0

Documentation

Overview

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2024 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2024 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Copyright 2023 Louis Royer and the NextMN-SRv6 contributors. All rights reserved. Use of this source code is governed by a MIT-style license that can be found in the LICENSE file. SPDX-License-Identifier: MIT

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ControllerRegistryTask added in v0.0.12 

type ControllerRegistryTask struct {
	WithName
	WithState
	ControllerRegistry *ctrl.ControllerRegistry
	SetupRegistry      app_api.Registry
}

ControllerRegistry registers and unregisters into controller

func NewControllerRegistryTask added in v0.0.12 

func NewControllerRegistryTask(name string, remoteControlURI string, backbone netip.Addr, locator string, localControlURI string, setup_registry app_api.Registry) *ControllerRegistryTask

Create a new ControllerRegistry

func (*ControllerRegistryTask) RunExit added in v0.0.12 

func (t *ControllerRegistryTask) RunExit() error

Exit

func (*ControllerRegistryTask) RunInit added in v0.0.12 

func (t *ControllerRegistryTask) RunInit() error

Init

type DBTask added in v0.0.12 

type DBTask struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

DBTask initializes the database

func NewDBTask added in v0.0.12 

func NewDBTask(name string, registry app_api.Registry) *DBTask

Create a new DBTask

func (*DBTask) RunExit added in v0.0.12 

func (db *DBTask) RunExit() error

Exit

func (*DBTask) RunInit added in v0.0.12 

func (db *DBTask) RunInit() error

Init

type FakeTask 

type FakeTask struct {
	WithName
	WithState
}

FakeTask is a dummy task that do nothing

func NewFakeTask 

func NewFakeTask(name string) *FakeTask

Create a new FakeTask

func (*FakeTask) RunExit 

func (t *FakeTask) RunExit() error

Exit

func (*FakeTask) RunInit 

func (t *FakeTask) RunInit() error

Init

type HookMulti 

type HookMulti struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

HookMulti is a Task that runs 2 SingleHook

func NewMultiHook 

func NewMultiHook(init_name string, init *string, exit_name string, exit *string) *HookMulti

Creates a new MultiHook

func (*HookMulti) NameBase added in v0.0.12 

func (h *HookMulti) NameBase() string

func (*HookMulti) NameExit added in v0.0.12 

func (h *HookMulti) NameExit() string

func (*HookMulti) NameInit added in v0.0.12 

func (h *HookMulti) NameInit() string

func (*HookMulti) RunExit 

func (h *HookMulti) RunExit() error

Exit function

func (*HookMulti) RunInit 

func (h *HookMulti) RunInit() error

Init function

type HttpServerTask added in v0.0.11 

type HttpServerTask struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

HttpServerTask starts an http server

func NewHttpServerTask added in v0.0.11 

func NewHttpServerTask(name string, httpAddr string, setupRegistry app_api.Registry) *HttpServerTask

Create a new HttpServerTask

func (*HttpServerTask) RunExit added in v0.0.11 

func (t *HttpServerTask) RunExit() error

Exit

func (*HttpServerTask) RunInit added in v0.0.11 

func (t *HttpServerTask) RunInit() error

Init

type Registry added in v0.0.12 

type Registry struct {
	Tasks []tasks_api.Task
}

func NewRegistry added in v0.0.12 

func NewRegistry() *Registry

func (*Registry) Register added in v0.0.12 

func (r *Registry) Register(task tasks_api.Task)

Register a new task

func (*Registry) RunExit added in v0.0.12 

func (r *Registry) RunExit()

Run exit tasks

func (*Registry) RunInit added in v0.0.12 

func (r *Registry) RunInit() error

Run init tasks

type SingleHook 

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

HookSingle

func NewSingleHook 

func NewSingleHook(name string, cmd *string) SingleHook

Creates a new SingleHook

func (SingleHook) Name added in v0.0.12 

func (h SingleHook) Name() string

func (SingleHook) Run 

func (h SingleHook) Run() error

Runs the command of the SingleHook

type TaskBlackhole 

type TaskBlackhole struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

TaskBlackhole

func NewTaskBlackhole 

func NewTaskBlackhole(name string, table_name string) *TaskBlackhole

Create a new TaskBlackhole

func (*TaskBlackhole) RunExit 

func (t *TaskBlackhole) RunExit() error

Delete blackhole

func (*TaskBlackhole) RunInit 

func (t *TaskBlackhole) RunInit() error

Create blackhole

type TaskDummyIface 

type TaskDummyIface struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

TaskDummyIface

func NewTaskDummyIface 

func NewTaskDummyIface(name string, iface_name string) *TaskDummyIface

Create a new Task for DummyIface

func (*TaskDummyIface) RunExit 

func (t *TaskDummyIface) RunExit() error

Delete the Iface

func (*TaskDummyIface) RunInit 

func (t *TaskDummyIface) RunInit() error

Create and set up the Iface

type TaskIPRule 

type TaskIPRule struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

TaskIPRule

func NewTaskIP4Rule 

func NewTaskIP4Rule(name string, prefix string, table_name string) *TaskIPRule

Create a new Task for IPRule

func NewTaskIP6Rule 

func NewTaskIP6Rule(name string, prefix string, table_name string) *TaskIPRule

Create a new Task for IPRule

func (*TaskIPRule) RunExit 

func (t *TaskIPRule) RunExit() error

Delete ip rules

func (*TaskIPRule) RunInit 

func (t *TaskIPRule) RunInit() error

Setup ip rules

type TaskLinuxEndpoint 

type TaskLinuxEndpoint struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

TaskLinuxEndpoint creates a new linux endpoint

func NewTaskLinuxEndpoint 

func NewTaskLinuxEndpoint(name string, endpoint *config.Endpoint, table_name string, iface_name string) *TaskLinuxEndpoint

Create a new TaskLinuxEndpoint

func (*TaskLinuxEndpoint) RunExit 

func (t *TaskLinuxEndpoint) RunExit() error

Exit

func (*TaskLinuxEndpoint) RunInit 

func (t *TaskLinuxEndpoint) RunInit() error

Init

type TaskLinuxHeadend 

type TaskLinuxHeadend struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

TaskLinuxHeadend creates a new linux headend

func NewTaskLinuxHeadend 

func NewTaskLinuxHeadend(name string, headend *config.Headend, table_name string, iface_name string) *TaskLinuxHeadend

Create a new TaskLinuxHeadend

func (*TaskLinuxHeadend) RunExit 

func (t *TaskLinuxHeadend) RunExit() error

Exit

func (*TaskLinuxHeadend) RunInit 

func (t *TaskLinuxHeadend) RunInit() error

Init

type TaskLinuxHeadendSetSourceAddress 

type TaskLinuxHeadendSetSourceAddress struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

TaskLinuxHeadendSetSourceAddress

func NewTaskLinuxHeadendSetSourceAddress 

func NewTaskLinuxHeadendSetSourceAddress(name string, address string) *TaskLinuxHeadendSetSourceAddress

Create a new TaskLinuxHeadendSetSourceAddress

func (*TaskLinuxHeadendSetSourceAddress) RunExit 

func (t *TaskLinuxHeadendSetSourceAddress) RunExit() error

Exit

func (*TaskLinuxHeadendSetSourceAddress) RunInit 

func (t *TaskLinuxHeadendSetSourceAddress) RunInit() error

Init

type TaskNextMNEndpoint 

type TaskNextMNEndpoint struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

TaskNextMNEndpoint creates a new endpoint

func NewTaskNextMNEndpoint 

func NewTaskNextMNEndpoint(name string, endpoint *config.Endpoint, table_name string, iface_name string, registry app_api.Registry, debug bool) *TaskNextMNEndpoint

Create a new TaskNextMNEndpoint

func (*TaskNextMNEndpoint) RunExit 

func (t *TaskNextMNEndpoint) RunExit() error

Exit

func (*TaskNextMNEndpoint) RunInit 

func (t *TaskNextMNEndpoint) RunInit() error

Init

type TaskNextMNHeadend 

type TaskNextMNHeadend struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

TaskNextMNHeadend creates a new headend

func NewTaskNextMNHeadend 

func NewTaskNextMNHeadend(name string, headend *config.Headend, table_name string, iface_name string, registry app_api.Registry, debug bool) *TaskNextMNHeadend

Create a new TaskNextMNHeadend

func (*TaskNextMNHeadend) RunExit 

func (t *TaskNextMNHeadend) RunExit() error

Exit

func (*TaskNextMNHeadend) RunInit 

func (t *TaskNextMNHeadend) RunInit() error

Init

type TaskNextMNHeadendWithCtrl added in v0.0.12 

type TaskNextMNHeadendWithCtrl struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

TaskNextMNHeadend creates a new headend

func NewTaskNextMNHeadendWithCtrl added in v0.0.12 

func NewTaskNextMNHeadendWithCtrl(name string, headend *config.Headend, table_name string, iface_name string, registry app_api.Registry, debug bool) *TaskNextMNHeadendWithCtrl

Create a new TaskNextMNHeadend

func (*TaskNextMNHeadendWithCtrl) RunExit added in v0.0.12 

func (t *TaskNextMNHeadendWithCtrl) RunExit() error

Exit

func (*TaskNextMNHeadendWithCtrl) RunInit added in v0.0.12 

func (t *TaskNextMNHeadendWithCtrl) RunInit() error

Init

type TaskTunIface 

type TaskTunIface struct {
	WithName
	WithState
	// contains filtered or unexported fields
}

TaskTunIface

func NewTaskTunIface 

func NewTaskTunIface(name string, iface_name string, registry app_api.Registry) *TaskTunIface

Create a new Task for TunIface

func (*TaskTunIface) RunExit 

func (t *TaskTunIface) RunExit() error

Delete the Iface

func (*TaskTunIface) RunInit 

func (t *TaskTunIface) RunInit() error

Create and set up the Iface

type WithName added in v0.0.12 

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

func NewName added in v0.0.12 

func NewName(name string) WithName

func (*WithName) NameBase added in v0.0.12 

func (wn *WithName) NameBase() string

func (*WithName) NameExit added in v0.0.12 

func (wn *WithName) NameExit() string

func (*WithName) NameInit added in v0.0.12 

func (wn *WithName) NameInit() string

type WithState 

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

func NewState 

func NewState() WithState

func (*WithState) State 

func (ws *WithState) State() bool

Source Files

View all Source files

Directories

Path Synopsis

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.