edgevpn

Jan 12, 2022

Changes in this version

type Config

+ ChannelBufferSize int

+ Concurrency int

type Option

+ func WithChannelBufferSize(i int) Option

+ func WithConcurrency(i int) Option

Jan 12, 2022

Changes in this version

type Config

+ Timeout time.Duration

type Option

+ func WithTimeout(s string) Option

Dec 26, 2021

Changes in this version

+ func WithRouterAddress(i string) func(cfg *Config) error

type Config

+ RouterAddress string

Dec 3, 2021

Changes in this version

+ func WithNetworkService(ns ...NetworkService) func(cfg *Config) error

type Config

+ NetworkServices []NetworkService

+ type NetworkService func(context.Context, *EdgeVPN, *blockchain.Ledger) error

Nov 8, 2021

Changes in this version

+ func WithDiscoveryBootstrapPeers(a discovery.AddrList) func(cfg *Config) error

+ func WithDiscoveryInterval(t time.Duration) func(cfg *Config) error

+ func WithLedgerAnnounceTime(t time.Duration) func(cfg *Config) error

+ func WithLedgerInterval(t time.Duration) func(cfg *Config) error

type Config

+ DiscoveryBootstrapPeers discovery.AddrList

+ DiscoveryInterval time.Duration

Nov 1, 2021

Changes in this version

+ func WithStore(s blockchain.Store) func(cfg *Config) error

type Config

+ Store blockchain.Store

Nov 1, 2021

Changes in this version

type YAMLConnectionConfig

+ MaxMessageSize int

Nov 1, 2021

Changes in this version

type EdgeVPN

+ func (e *EdgeVPN) Ledger() (*blockchain.Ledger, error)

type YAMLConnectionConfig

+ MaxBlockChainLength int

Oct 31, 2021

Changes in this version

+ func LibP2PLogLevel(l log.LogLevel) func(cfg *Config) error

type EdgeVPN

+ func (e *EdgeVPN) Logger() log.StandardLogger

Oct 31, 2021

Changes in this version

+ const FileProtocol

+ const FilesLedgerKey

type EdgeVPN

+ func (e *EdgeVPN) ReceiveFile(ledger *blockchain.Ledger, fileID string, path string) error

+ func (e *EdgeVPN) SendFile(ledger *blockchain.Ledger, fileID, filepath string) error

Oct 30, 2021

Changes in this version

+ const MachinesLedgerKey

+ const ServiceProtocol

+ const ServicesLedgerKey

+ const UsersLedgerKey

type EdgeVPN

+ func (e *EdgeVPN) ConnectToService(ledger *blockchain.Ledger, serviceID string, srcaddr string) error

+ func (e *EdgeVPN) ExposeService(ledger *blockchain.Ledger, serviceID, dstaddress string)

Oct 29, 2021

Changes in this version

+ func WithStreamHandler(id protocol.ID, h StreamHandler) func(cfg *Config) error

type Config

+ LedgerAnnounceTime time.Duration

+ LedgerSyncronizationTime time.Duration

+ StreamHandlers map[protocol.ID]StreamHandler

type EdgeVPN

+ func (e *EdgeVPN) Join(ledger *blockchain.Ledger) error

+ type StreamHandler func(stream network.Stream)

Oct 27, 2021

Changes in this version

+ func FromBase64(bb string) func(cfg *Config) error

Oct 27, 2021

Changes in this version

+ const Protocol

+ func WithMaxBlockChainSize(i int) func(cfg *Config) error

+ func WithPacketMTU(i int) func(cfg *Config) error

type Config

+ MaxBlockChainLength int

type MessageWriter

+ func (mw *MessageWriter) WriteString(p string) (n int, err error)

Oct 14, 2021

Changes in this version

+ func WithLibp2pAdditionalOptions(i ...libp2p.Option) func(cfg *Config) error

type Config

+ AdditionalOptions []libp2p.Option

Sep 21, 2021

Changes in this version

+ func NetLinkBootstrap(b bool) func(cfg *Config) error

+ func WithLibp2pOptions(i ...libp2p.Option) func(cfg *Config) error

type Config

+ NetLinkBootstrap bool

+ Options []libp2p.Option

May 15, 2021

Changes in this version

+ func DiscoveryService(s ...ServiceDiscovery) func(cfg *Config) error

+ func ExchangeKeys(s string) func(cfg *Config) error

+ func FromYaml(path string) func(cfg *Config) error

+ func Handlers(h ...Handler) func(cfg *Config) error

+ func Insecure(b bool) func(cfg *Config) error

+ func ListenAddresses(s string) func(cfg *Config) error

+ func LogLevel(l log.LogLevel) func(cfg *Config) error

+ func Logger(l *zap.Logger) func(cfg *Config) error

+ func MaxMessageSize(i int) func(cfg *Config) error

+ func Message(template string, opts ...interface{}) []byte

+ func RoomName(s string) func(cfg *Config) error

+ func SealKeyInterval(i int) func(cfg *Config) error

+ func SealKeyLength(i int) func(cfg *Config) error

+ func WithInterface(i *water.Interface) func(cfg *Config) error

+ func WithInterfaceAddress(i string) func(cfg *Config) error

+ func WithInterfaceMTU(i int) func(cfg *Config) error

+ func WithInterfaceName(i string) func(cfg *Config) error

+ func WithInterfaceType(d water.DeviceType) func(cfg *Config) error

+ func WithMTU(i int) func(cfg *Config) error

+ type Config struct

+ DeviceType water.DeviceType

+ ExchangeKey string

+ Handle func(bool, *hub.Message)

+ Handlers []Handler

+ Insecure bool

+ Interface *water.Interface

+ InterfaceAddress string

+ InterfaceMTU int

+ InterfaceName string

+ ListenAddresses discovery.AddrList

+ Logger *zap.Logger

+ MTU int

+ MaxMessageSize int

+ RoomName string

+ SealKeyInterval int

+ SealKeyLength int

+ ServiceDiscovery []ServiceDiscovery

+ func (cfg *Config) Apply(opts ...Option) error

+ type EdgeVPN struct

+ HubRoom *hub.Room

+ func New(p ...Option) *EdgeVPN

+ func (e *EdgeVPN) Host() host.Host

+ func (e *EdgeVPN) MessageWriter(opts ...hub.MessageOption) (*MessageWriter, error)

+ func (e *EdgeVPN) Start() error

+ func (e *EdgeVPN) Stop()

+ type Handler func(*hub.Message) error

+ func IfaceWriter(i *water.Interface) Handler

+ type MessageWriter struct

+ func (mw *MessageWriter) Send(copy *hub.Message) (n int, err error)

+ func (mw *MessageWriter) Write(p []byte) (n int, err error)

+ type OTP struct

+ Crypto OTPConfig

+ DHT OTPConfig

+ type OTPConfig struct

+ Interval int

+ Key string

+ Length int

+ type Option func(cfg *Config) error

+ type ServiceDiscovery interface

+ Option func(context.Context) func(c *libp2p.Config) error

+ Run func(*zap.Logger, context.Context, host.Host) error

+ type YAMLConnectionConfig struct

+ MDNS string

+ OTP OTP

+ Rendezvous string

+ RoomName string

+ func GenerateNewConnectionData() (*YAMLConnectionConfig, error)

+ func (y YAMLConnectionConfig) Fill(cfg *Config)