fleet

Apr 11, 2024

Changes in this version

type Agent

+ func (a *Agent) ExternalKey() (crypto.PrivateKey, error)

+ func (a *Agent) InternalKey() (crypto.PrivateKey, error)

Feb 13, 2024

Changes in this version

type Agent

+ func (a *Agent) DialPeer(host string, port int, id string, alt ...string)

Nov 25, 2023

Changes in this version

+ func IsReady() bool

Jun 30, 2023

Changes in this version

type Agent

+ func (a *Agent) GetStringSetting(v string) string

Jun 24, 2023

Changes in this version

type Agent

+ func (a *Agent) GetStatus() int

+ func (a *Agent) Settings() (map[string]any, error)

+ func (a *Agent) WaitReady()

Jun 16, 2023

retracted

Changes in this version

+ const PacketRpcBinReq

+ const PacketRpcBinRes

Jun 15, 2023

retracted

Changes in this version

type RPC

+ CountAllPeers func() int

+ ListOnlinePeers func() []string

Jun 13, 2023

retracted

Changes in this version

type Agent

+ func (a *Agent) AllRpcRequest(ctx context.Context, endpoint string, data []byte) ([]any, error)

+ func (a *Agent) BroadcastRpcBin(ctx context.Context, endpoint string, pkt []byte) (n int, err error)

+ func (a *Agent) RpcRequest(ctx context.Context, id string, endpoint string, data []byte) ([]byte, error)

+ func (a *Agent) RpcSend(ctx context.Context, id string, endpoint string, data []byte) error

type RPC

+ Request func(ctx context.Context, id string, data []byte) ([]byte, error)

May 31, 2023

retracted

Changes in this version

type Agent

+ func (a *Agent) NewRpcInstance(name string) (RPC, error)

+ type RPC interface

+ All func(ctx context.Context, data any) ([]any, error)

+ Broadcast func(ctx context.Context, data any) error

+ Connect func(cb func(context.Context, any) (any, error))

+ Self func() string

+ Send func(ctx context.Context, id string, data any) (any, error)

May 26, 2023

Changes in this version

type Peer

+ func (p *Peer) RemoteAddr() net.Addr

May 25, 2023

Changes in this version

type Agent

+ func (a *Agent) SwitchChannel(channel string) error

type PacketHandshake

+ Channel string

Mar 14, 2023

Changes in this version

+ func GetSelfsignedCertificate(n string) (*tls.Certificate, error)

Mar 13, 2023

Changes in this version

type Agent

+ func (a *Agent) DbDelete(key string) error

May 15, 2022

Changes in this version

type Agent

+ func (a *Agent) GetInternalCertificate(h *tls.ClientHelloInfo) (*tls.Certificate, error)

+ func (a *Agent) GetPublicCertificate(h *tls.ClientHelloInfo) (*tls.Certificate, error)

May 7, 2022

Changes in this version

type Peer

+ func (p *Peer) String() string

May 2, 2022

Changes in this version

+ const PacketHeaderSize

+ const PacketMaxBody

Mar 13, 2022

Changes in this version

type Agent

+ func (a *Agent) DebugLocks(w io.Writer)

Mar 13, 2022

Changes in this version

+ func UniqueTimestamp() uint64

Mar 13, 2022

Changes in this version

+ const Aye

+ const Nay

+ const PacketLockConfirm

+ const PacketLockRelease

+ const PacketLockReq

+ const PacketLockRes

+ var ErrCancelledLock = errors.New("lock request has been cancelled")

+ var ErrInvalidLockName = errors.New("invalid lock name")

+ func TlsProtocols() []string

type Agent

+ func (a *Agent) GetPeersCount() uint32

+ func (a *Agent) Lock(ctx context.Context, name string) (*LocalLock, error)

+ type AgentOption interface

+ type LocalLock struct

+ func (lk *LocalLock) Release()

+ type OptionListener struct

+ type OptionPort int

Feb 22, 2022

Changes in this version

type Agent

+ func (a *Agent) MetaSet(key string, value interface{})

type PacketAnnounce

+ Meta map[string]interface{}

type Peer

+ func (p *Peer) Meta() map[string]interface{}

Feb 20, 2022

Changes in this version

type Agent

+ func (a *Agent) CacheDir() string

Feb 20, 2022

Changes in this version

type Agent

+ func (a *Agent) CountPeers() int

Feb 20, 2022

Changes in this version

+ var ErrInvalidLegacy = errors.New("invalid operation on legacy peer")

Feb 20, 2022

Changes in this version

+ const PacketCustom

+ const PacketCustomMax

+ func Custom(v uint16) uint16

+ func SetCustomHandler(pc uint16, h CustomHandler)

type Agent

+ func (a *Agent) BroadcastPacket(ctx context.Context, pc uint16, data []byte) error

+ func (a *Agent) SendPacketTo(ctx context.Context, target string, pc uint16, data []byte) error

+ type CustomHandler func(p *Peer, data []byte) error

type Peer

+ func (p *Peer) Agent() *Agent

+ func (p *Peer) Division() string

+ func (p *Peer) Id() string

+ func (p *Peer) Name() string

Feb 12, 2022

Changes in this version

type Agent

+ func (a *Agent) GetInternalTlsConfig() (*tls.Config, error)

Feb 10, 2022

Changes in this version

+ const PacketLegacy

+ const PacketMaxLen

+ const PacketPing

type Agent

+ func (a *Agent) AllRPC(ctx context.Context, endpoint string, data interface{}) ([]interface{}, error)

type DbStamp

+ func (t DbStamp) Bytes() []byte

type Peer

+ func (p *Peer) WritePacket(pc uint16, data []byte) error

+ func (p *Peer) Writev(buf ...[]byte) (n int, err error)

Feb 9, 2022

Changes in this version

type Agent

+ IP string

Feb 9, 2022

Changes in this version

type Agent

+ func (a *Agent) KeyShake128(N []byte) (sha3.ShakeHash, error)

+ func (a *Agent) KeyShake256(N []byte) (sha3.ShakeHash, error)

+ func (a *Agent) SeedShake128(N []byte) sha3.ShakeHash

+ func (a *Agent) SeedShake256(N []byte) sha3.ShakeHash

Feb 1, 2022

Changes in this version

type Agent

+ GetFile GetFileFunc

+ func New() *Agent

+ func Self() *Agent

+ func WithGetFile(f GetFileFunc) *Agent

+ func WithIssuer(url string) (a *Agent)

+ func (a *Agent) AddService(service string) chan net.Conn

+ func (a *Agent) AnyRpc(ctx context.Context, division string, endpoint string, data interface{}) error

+ func (a *Agent) BroadcastRpc(ctx context.Context, endpoint string, data interface{}) error

+ func (a *Agent) Close()

+ func (a *Agent) ConfigureTlsServer(cfg *tls.Config)

+ func (a *Agent) Connect(id string, service string) (net.Conn, error)

+ func (a *Agent) DbGet(key string) (string, error)

+ func (a *Agent) DbSet(key string, value []byte) error

+ func (a *Agent) DbWatch(key string, cb func(string, []byte))

+ func (a *Agent) Dial(network, addr string) (net.Conn, error)

+ func (a *Agent) DialContext(c context.Context, network, addr string) (net.Conn, error)

+ func (a *Agent) DivisionPrefixRpc(ctx context.Context, divMatch string, endpoint string, data interface{}) error

+ func (a *Agent) DivisionRpc(ctx context.Context, division int, endpoint string, data interface{}) error

+ func (a *Agent) DumpInfo(w io.Writer)

+ func (a *Agent) GenInternalCert() (tls.Certificate, error)

+ func (a *Agent) GetCA() (*x509.CertPool, error)

+ func (a *Agent) GetClientTlsConfig() (*tls.Config, error)

+ func (a *Agent) GetDefaultPublicCert() (tls.Certificate, error)

+ func (a *Agent) GetInternalCert() (tls.Certificate, error)

+ func (a *Agent) GetPeer(id string) *Peer

+ func (a *Agent) GetPeerByName(name string) *Peer

+ func (a *Agent) GetPeers() []*Peer

+ func (a *Agent) GetTlsConfig() (*tls.Config, error)

+ func (a *Agent) Id() string

+ func (a *Agent) IsConnected(id string) bool

+ func (a *Agent) LogDmesg(w io.Writer) (int64, error)

+ func (a *Agent) LogTarget() io.Writer

+ func (a *Agent) Name() (string, string)

+ func (a *Agent) NewDbCursor(bucket []byte) (*DbCursor, error)

+ func (a *Agent) RPC(ctx context.Context, id string, endpoint string, data interface{}) (interface{}, error)

+ func (a *Agent) RoundTripper() http.RoundTripper

+ func (a *Agent) SeedCrypt(in []byte) ([]byte, error)

+ func (a *Agent) SeedDecrypt(in []byte) ([]byte, error)

+ func (a *Agent) SeedId() uuid.UUID

+ func (a *Agent) SeedSign(in []byte) []byte

+ func (a *Agent) SeedTlsConfig(c *tls.Config)

+ func (a *Agent) SendTo(ctx context.Context, target string, pkt interface{}) error

+ func (a *Agent) TrySendTo(target string, pkt interface{}) error

+ type GetFileFunc func(string) ([]byte, error)

Jan 30, 2022

Changes in this version

type AgentObj

+ func (a *AgentObj) TrySendTo(target string, pkt interface{}) error

type Peer

+ func (p *Peer) TrySend(pkt Packet) error

Jan 30, 2022

Changes in this version

+ var ErrConnectionClosed = errors.New("connection has been closed")

Jan 30, 2022

Changes in this version

+ var ErrPeerNoRoute = errors.New("no route to peer")

+ var ErrWriteQueueFull = errors.New("peer write queue is full")

+ type PacketAlive struct

+ Now time.Time

Jan 20, 2022

Changes in this version

+ func CallRpcEndpoint(e string, p interface{}) (interface{}, error)

Jan 16, 2022

Changes in this version

+ type PacketClose struct

+ Reason string

type Peer

+ func (p *Peer) Close(reason string) error

Jan 14, 2022

Changes in this version

+ func DbWatch(key string, cb func(string, []byte))

+ type DbWatchCallback func(string, []byte)

Jan 3, 2022

Changes in this version

+ type PacketDbRequest struct

+ Bucket []byte

+ Key []byte

+ SourceId string

+ TargetId string

+ type PacketDbVersions struct

+ Info []*PacketDbVersionsEntry

+ type PacketDbVersionsEntry struct

+ Bucket []byte

+ Key []byte

+ Stamp DbStamp

Jan 2, 2022

Changes in this version

+ const UUID_SEEDID_SPACE

+ var Agent = &AgentObj

+ var GetFile func(string) ([]byte, error)

+ func ConfigureTlsServer(cfg *tls.Config)

+ func DbGet(key string) (string, error)

+ func DbSet(key string, value []byte) error

+ func EnsureDir(c string) error

+ func GenInternalCert() (tls.Certificate, error)

+ func GetCA() (*x509.CertPool, error)

+ func GetClientTlsConfig() (*tls.Config, error)

+ func GetDefaultPublicCert() (tls.Certificate, error)

+ func GetInternalCert() (tls.Certificate, error)

+ func GetTlsConfig() (*tls.Config, error)

+ func Init()

+ func LogDmesg(w io.Writer) (int64, error)

+ func LogTarget() io.Writer

+ func SeedCrypt(in []byte) ([]byte, error)

+ func SeedDecrypt(in []byte) ([]byte, error)

+ func SeedId() uuid.UUID

+ func SeedSign(in []byte) []byte

+ func SeedTlsConfig(c *tls.Config)

+ func SetIssuer(url string)

+ func SetRpcEndpoint(e string, f RpcEndpoint)

+ func Shutdown()

+ type AgentObj struct

+ func (a *AgentObj) AddService(service string) chan net.Conn

+ func (a *AgentObj) AnyRpc(division string, endpoint string, data interface{}) error

+ func (a *AgentObj) BroadcastRpc(endpoint string, data interface{}) error

+ func (a *AgentObj) Connect(id string, service string) (net.Conn, error)

+ func (a *AgentObj) Dial(network, addr string) (net.Conn, error)

+ func (a *AgentObj) DialContext(c context.Context, network, addr string) (net.Conn, error)

+ func (a *AgentObj) DivisionPrefixRpc(divMatch string, endpoint string, data interface{}) error

+ func (a *AgentObj) DivisionRpc(division int, endpoint string, data interface{}) error

+ func (a *AgentObj) DumpInfo(w io.Writer)

+ func (a *AgentObj) GetPeer(id string) *Peer

+ func (a *AgentObj) GetPeerByName(name string) *Peer

+ func (a *AgentObj) Id() string

+ func (a *AgentObj) IsConnected(id string) bool

+ func (a *AgentObj) Name() (string, string)

+ func (a *AgentObj) RPC(id string, endpoint string, data interface{}) (interface{}, error)

+ func (a *AgentObj) RoundTripper() http.RoundTripper

+ func (a *AgentObj) SendTo(target string, pkt interface{}) error

+ type DbCursor struct

+ func NewDbCursor(bucket []byte) (*DbCursor, error)

+ func (c *DbCursor) Close() error

+ func (c *DbCursor) First() ([]byte, []byte)

+ func (c *DbCursor) Last() ([]byte, []byte)

+ func (c *DbCursor) Next() ([]byte, []byte)

+ func (c *DbCursor) Seek(pfx []byte) ([]byte, []byte)

+ type DbStamp time.Time

+ func DbNow() DbStamp

+ func DbZero() DbStamp

+ func (t *DbStamp) GobDecode(data []byte) error

+ func (t *DbStamp) UnmarshalBinary(data []byte) error

+ func (t DbStamp) After(t2 DbStamp) bool

+ func (t DbStamp) GobEncode() ([]byte, error)

+ func (t DbStamp) MarshalBinary() ([]byte, error)

+ func (t DbStamp) String() string

+ func (t DbStamp) Unix() int64

+ func (t DbStamp) UnixNano() int64

+ type Packet interface

+ type PacketAnnounce struct

+ AZ string

+ Id string

+ Idx uint64

+ Now time.Time

+ NumG uint32

+ type PacketDbRecord struct

+ Bucket []byte

+ Key []byte

+ SourceId string

+ Stamp DbStamp

+ TargetId string

+ Val []byte

+ type PacketHandshake struct

+ Build string

+ Division string

+ Git string

+ Id string

+ Name string

+ Now time.Time

+ type PacketPong struct

+ Now time.Time

+ SourceId string

+ TargetId string

+ type PacketRpc struct

+ Data interface{}

+ Endpoint string

+ R uintptr

+ SourceId string

+ TargetId string

+ type PacketRpcResponse struct

+ Data interface{}

+ Error string

+ HasError bool

+ R uintptr

+ SourceId string

+ TargetId string

+ type PacketSeed struct

+ Seed []byte

+ Time time.Time

+ type Peer struct

+ Ping time.Duration

+ func (p *Peer) Send(pkt Packet) error

+ type RpcEndpoint func(interface{}) (interface{}, error)

+ type ServiceConn struct

+ type SortablePeers []*Peer

+ func (s SortablePeers) Len() int

+ func (s SortablePeers) Less(i, j int) bool

+ func (s SortablePeers) Swap(i, j int)