network

README

Network

Example

grpc_cli call localhost:20182 n0stack.pool.NetworkService/ListNetworks ''

grpc_cli call localhost:20182 n0stack.pool.NetworkService/GetNetwork '
name: "test-network"
'

grpc_cli call localhost:20182 n0stack.pool.NetworkService/ApplyNetwork '
name: "test-network"
ipv4_cidr: "10.100.100.0/24"
domain: "test.local"
'

grpc_cli call localhost:20182 n0stack.pool.NetworkService/ReserveNetworkInterface '
name: "test-network"
network_interface_name: "test-reserve"
'

grpc_cli call localhost:20182 n0stack.pool.NetworkService/ReleaseNetworkInterface '
name: "test-network"
network_interface_name: "test-reserve"
'

Documentation

Index

• Constants
• func CheckConflictIPv4(request net.IP, reserved map[string]*pbudget.NetworkInterface) error
• func CheckIPv4OnCIDR(request net.IP, cidr *net.IPNet) error
• func IsLockedForDeletion(network *ppool.Network) bool
• func ScheduleNewIPv4(cidr *net.IPNet, reserved map[string]*pbudget.NetworkInterface) net.IP
• type MockNetworkAPI
  • func NewMockNetworkAPI(datastore *memory.MemoryDatastore) *MockNetworkAPI
  • func (a MockNetworkAPI) ApplyNetwork(ctx context.Context, in *ppool.ApplyNetworkRequest, opts ...grpc.CallOption) (*ppool.Network, error)
  • func (a MockNetworkAPI) DeleteNetwork(ctx context.Context, in *ppool.DeleteNetworkRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (a MockNetworkAPI) FactoryNetwork(ctx context.Context) (*ppool.Network, error)
  • func (a MockNetworkAPI) GetNetwork(ctx context.Context, in *ppool.GetNetworkRequest, opts ...grpc.CallOption) (*ppool.Network, error)
  • func (a MockNetworkAPI) ListNetworks(ctx context.Context, in *ppool.ListNetworksRequest, opts ...grpc.CallOption) (*ppool.ListNetworksResponse, error)
  • func (a MockNetworkAPI) ReleaseNetworkInterface(ctx context.Context, in *ppool.ReleaseNetworkInterfaceRequest, ...) (*empty.Empty, error)
  • func (a MockNetworkAPI) ReserveNetworkInterface(ctx context.Context, in *ppool.ReserveNetworkInterfaceRequest, ...) (*ppool.Network, error)
• type NetworkAPI
  • func CreateNetworkAPI(ds datastore.Datastore) *NetworkAPI
  • func (a NetworkAPI) ApplyNetwork(ctx context.Context, req *ppool.ApplyNetworkRequest) (*ppool.Network, error)
  • func (a NetworkAPI) DeleteNetwork(ctx context.Context, req *ppool.DeleteNetworkRequest) (*empty.Empty, error)
  • func (a NetworkAPI) GetNetwork(ctx context.Context, req *ppool.GetNetworkRequest) (*ppool.Network, error)
  • func (a NetworkAPI) ListNetworks(ctx context.Context, req *ppool.ListNetworksRequest) (*ppool.ListNetworksResponse, error)
  • func (a NetworkAPI) ReleaseNetworkInterface(ctx context.Context, req *ppool.ReleaseNetworkInterfaceRequest) (*empty.Empty, error)
  • func (a NetworkAPI) ReserveNetworkInterface(ctx context.Context, req *ppool.ReserveNetworkInterfaceRequest) (*ppool.Network, error)

Constants

const AnnotationNetworkInterfaceDisableDeletionLock = "n0core/pool/network/disable_deletion_lock"

Functions

func CheckConflictIPv4

func CheckConflictIPv4(request net.IP, reserved map[string]*pbudget.NetworkInterface) error

func CheckIPv4OnCIDR

func CheckIPv4OnCIDR(request net.IP, cidr *net.IPNet) error

func IsLockedForDeletion

func IsLockedForDeletion(network *ppool.Network) bool

func ScheduleNewIPv4

func ScheduleNewIPv4(cidr *net.IPNet, reserved map[string]*pbudget.NetworkInterface) net.IP

O(len(reserved) ^ 2) なので要修正

Types

type MockNetworkAPI

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

func NewMockNetworkAPI

func NewMockNetworkAPI(datastore *memory.MemoryDatastore) *MockNetworkAPI

func (MockNetworkAPI) ApplyNetwork

func (a MockNetworkAPI) ApplyNetwork(ctx context.Context, in *ppool.ApplyNetworkRequest, opts ...grpc.CallOption) (*ppool.Network, error)

func (MockNetworkAPI) DeleteNetwork

func (a MockNetworkAPI) DeleteNetwork(ctx context.Context, in *ppool.DeleteNetworkRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (MockNetworkAPI) FactoryNetwork

func (a MockNetworkAPI) FactoryNetwork(ctx context.Context) (*ppool.Network, error)

func (MockNetworkAPI) GetNetwork

func (a MockNetworkAPI) GetNetwork(ctx context.Context, in *ppool.GetNetworkRequest, opts ...grpc.CallOption) (*ppool.Network, error)

func (MockNetworkAPI) ListNetworks

func (a MockNetworkAPI) ListNetworks(ctx context.Context, in *ppool.ListNetworksRequest, opts ...grpc.CallOption) (*ppool.ListNetworksResponse, error)

func (MockNetworkAPI) ReleaseNetworkInterface

func (a MockNetworkAPI) ReleaseNetworkInterface(ctx context.Context, in *ppool.ReleaseNetworkInterfaceRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (MockNetworkAPI) ReserveNetworkInterface

func (a MockNetworkAPI) ReserveNetworkInterface(ctx context.Context, in *ppool.ReserveNetworkInterfaceRequest, opts ...grpc.CallOption) (*ppool.Network, error)

type NetworkAPI

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

func CreateNetworkAPI

func CreateNetworkAPI(ds datastore.Datastore) *NetworkAPI

func (NetworkAPI) ApplyNetwork

func (a NetworkAPI) ApplyNetwork(ctx context.Context, req *ppool.ApplyNetworkRequest) (*ppool.Network, error)

func (NetworkAPI) DeleteNetwork

func (a NetworkAPI) DeleteNetwork(ctx context.Context, req *ppool.DeleteNetworkRequest) (*empty.Empty, error)

func (NetworkAPI) GetNetwork

func (a NetworkAPI) GetNetwork(ctx context.Context, req *ppool.GetNetworkRequest) (*ppool.Network, error)

func (NetworkAPI) ListNetworks

func (a NetworkAPI) ListNetworks(ctx context.Context, req *ppool.ListNetworksRequest) (*ppool.ListNetworksResponse, error)

func (NetworkAPI) ReleaseNetworkInterface

func (a NetworkAPI) ReleaseNetworkInterface(ctx context.Context, req *ppool.ReleaseNetworkInterfaceRequest) (*empty.Empty, error)

func (NetworkAPI) ReserveNetworkInterface

func (a NetworkAPI) ReserveNetworkInterface(ctx context.Context, req *ppool.ReserveNetworkInterfaceRequest) (*ppool.Network, error)

とりあえず IPv4 のスケジューリングのみに対応