database

package

Go to main page

Versions in this module

v0

v0.3.2

Nov 12, 2023

v0.3.1

Nov 8, 2023

v0.3.0

Oct 29, 2023

v0.2.13

Oct 16, 2023

v0.2.12

Oct 16, 2023

v0.2.11

Oct 15, 2023

v0.2.10

Oct 15, 2023

v0.2.9

Oct 15, 2023

v0.2.8

Oct 15, 2023

v0.2.7

Oct 15, 2023

v0.2.6

Oct 15, 2023

v0.2.5

Oct 15, 2023

v0.2.4

Oct 15, 2023

v0.2.3

Oct 15, 2023

v0.2.2

Oct 15, 2023

Changes in this version

type Database

+ func NewFromClient(cli client.Client, opts Options) *Database

v0.2.1

Oct 15, 2023

v0.2.0

Oct 14, 2023

v0.1.5

Oct 14, 2023

Changes in this version

type MeshState

+ func (st *MeshState) SetMeshState(ctx context.Context, state types.NetworkState) error

v0.1.4

Oct 12, 2023

Changes in this version

+ func HashLabelValue(addr string) string

v0.1.3

Oct 12, 2023

Changes in this version

type Database

+ func (db *Database) GetPeerByIPv4Addr(ctx context.Context, addr netip.Prefix) (types.MeshNode, error)

+ func (db *Database) GetPeerByIPv6Addr(ctx context.Context, addr netip.Prefix) (types.MeshNode, error)

v0.1.2

Oct 12, 2023

v0.1.1

Oct 11, 2023

Changes in this version

+ func HashEdge(source, target types.NodeID) (string, error)

+ func HashNodeID(id types.NodeID) (string, error)

v0.1.0

Oct 11, 2023

v0.0.9

Oct 11, 2023

v0.0.8

Oct 11, 2023

v0.0.7

Oct 9, 2023

v0.0.6

Oct 8, 2023

Changes in this version

type MeshState

+ func (st *MeshState) GetMeshState(ctx context.Context) (types.NetworkState, error)

v0.0.5

Oct 7, 2023

v0.0.4

Oct 6, 2023

v0.0.3

Oct 6, 2023

v0.0.2

Oct 5, 2023

Changes in this version

type Database

+ func NewDB(mgr manager.Manager, opts Options) (*Database, error)

+ func (db *Database) GraphStore() storage.GraphStore

+ func (db *Database) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

type GraphStore

+ func (g *GraphStore) Subscribe(ctx context.Context, fn storage.PeerSubscribeFunc) (context.CancelFunc, error)

v0.0.1

Oct 3, 2023

Changes in this version

+ const MeshStateConfigName

+ const RBACEnabledConfigMap

+ const RouteNodeLabel

+ func HashEncodedKey(encoded string) (string, error)

+ func SumKey(key crypto.PublicKey) (string, error)

+ func TruncateNodeID(id types.NodeID) string

+ type Database struct

+ func New(mgr manager.Manager, opts Options) (*Database, error)

+ func (db *Database) Close() error

+ func (db *Database) MeshState() storage.MeshState

+ func (db *Database) Networking() storage.Networking

+ func (db *Database) PeerGraph() types.PeerGraph

+ func (db *Database) Peers() storage.Peers

+ func (db *Database) RBAC() storage.RBAC

+ type GraphStore struct

+ func NewGraphStore(cli client.Client, namespace string) *GraphStore

+ func (g *GraphStore) AddEdge(sourceNode, targetNode types.NodeID, edge graph.Edge[types.NodeID]) error

+ func (g *GraphStore) AddVertex(nodeID types.NodeID, node types.MeshNode, props graph.VertexProperties) error

+ func (g *GraphStore) Edge(sourceNode, targetNode types.NodeID) (graph.Edge[types.NodeID], error)

+ func (g *GraphStore) ListEdges() ([]graph.Edge[types.NodeID], error)

+ func (g *GraphStore) ListVertices() ([]types.NodeID, error)

+ func (g *GraphStore) RemoveEdge(sourceNode, targetNode types.NodeID) error

+ func (g *GraphStore) RemoveVertex(nodeID types.NodeID) error

+ func (g *GraphStore) UpdateEdge(sourceNode, targetNode types.NodeID, edge graph.Edge[types.NodeID]) error

+ func (g *GraphStore) Vertex(nodeID types.NodeID) (node types.MeshNode, props graph.VertexProperties, err error)

+ func (g *GraphStore) VertexCount() (int, error)

+ type MeshState struct

+ func NewMeshState(cli client.Client, namespace string) *MeshState

+ func (st *MeshState) GetIPv4Prefix(ctx context.Context) (netip.Prefix, error)

+ func (st *MeshState) GetIPv6Prefix(ctx context.Context) (netip.Prefix, error)

+ func (st *MeshState) GetMeshDomain(ctx context.Context) (string, error)

+ func (st *MeshState) SetIPv4Prefix(ctx context.Context, prefix netip.Prefix) error

+ func (st *MeshState) SetIPv6Prefix(ctx context.Context, prefix netip.Prefix) error

+ func (st *MeshState) SetMeshDomain(ctx context.Context, domain string) error

+ type Networking struct

+ func NewNetworking(cli client.Client, namespace string) *Networking

+ func (nw *Networking) DeleteNetworkACL(ctx context.Context, name string) error

+ func (nw *Networking) DeleteRoute(ctx context.Context, name string) error

+ func (nw *Networking) GetNetworkACL(ctx context.Context, name string) (types.NetworkACL, error)

+ func (nw *Networking) GetRoute(ctx context.Context, name string) (types.Route, error)

+ func (nw *Networking) GetRoutesByCIDR(ctx context.Context, cidr netip.Prefix) (types.Routes, error)

+ func (nw *Networking) GetRoutesByNode(ctx context.Context, nodeID types.NodeID) (types.Routes, error)

+ func (nw *Networking) ListNetworkACLs(ctx context.Context) (types.NetworkACLs, error)

+ func (nw *Networking) ListRoutes(ctx context.Context) (types.Routes, error)

+ func (nw *Networking) PutNetworkACL(ctx context.Context, acl types.NetworkACL) error

+ func (nw *Networking) PutRoute(ctx context.Context, route types.Route) error

+ type Options struct

+ ListenAddr *net.TCPAddr

+ Namespace string

+ NodeID types.NodeID

+ type Peers struct

+ func NewPeers(cli client.Client, opts Options) *Peers

+ func (p *Peers) Delete(ctx context.Context, id types.NodeID) error

+ func (p *Peers) Get(ctx context.Context, id types.NodeID) (types.MeshNode, error)

+ func (p *Peers) GetByPubKey(ctx context.Context, key crypto.PublicKey) (types.MeshNode, error)

+ func (p *Peers) GetEdge(ctx context.Context, from, to types.NodeID) (types.MeshEdge, error)

+ func (p *Peers) List(ctx context.Context, filters ...storage.PeerFilter) ([]types.MeshNode, error)

+ func (p *Peers) ListIDs(ctx context.Context) ([]types.NodeID, error)

+ func (p *Peers) Put(ctx context.Context, n types.MeshNode) error

+ func (p *Peers) PutEdge(ctx context.Context, edge types.MeshEdge) error

+ func (p *Peers) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (p *Peers) RemoveEdge(ctx context.Context, from, to types.NodeID) error

+ func (p *Peers) Subscribe(ctx context.Context, fn storage.PeerSubscribeFunc) (context.CancelFunc, error)

+ type RBAC struct

+ func NewRBAC(cli client.Client, namespace string) *RBAC

+ func (r *RBAC) DeleteGroup(ctx context.Context, name string) error

+ func (r *RBAC) DeleteRole(ctx context.Context, name string) error

+ func (r *RBAC) DeleteRoleBinding(ctx context.Context, name string) error

+ func (r *RBAC) GetEnabled(ctx context.Context) (bool, error)

+ func (r *RBAC) GetGroup(ctx context.Context, name string) (types.Group, error)

+ func (r *RBAC) GetRole(ctx context.Context, name string) (types.Role, error)

+ func (r *RBAC) GetRoleBinding(ctx context.Context, name string) (types.RoleBinding, error)

+ func (r *RBAC) ListGroups(ctx context.Context) ([]types.Group, error)

+ func (r *RBAC) ListNodeRoles(ctx context.Context, nodeID types.NodeID) (types.RolesList, error)

+ func (r *RBAC) ListRoleBindings(ctx context.Context) ([]types.RoleBinding, error)

+ func (r *RBAC) ListRoles(ctx context.Context) (types.RolesList, error)

+ func (r *RBAC) ListUserRoles(ctx context.Context, userID types.NodeID) (types.RolesList, error)

+ func (r *RBAC) PutGroup(ctx context.Context, group types.Group) error

+ func (r *RBAC) PutRole(ctx context.Context, role types.Role) error

+ func (r *RBAC) PutRoleBinding(ctx context.Context, rolebinding types.RoleBinding) error

+ func (r *RBAC) SetEnabled(ctx context.Context, enabled bool) error

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