rpc25519

Jan 5, 2025

Changes in this version

type HDR

+ Args map[string]string

+ ServiceName string

Jan 5, 2025

Changes in this version

+ type ServeBistreamState struct

+ func (bi *ServeBistreamState) ServeBistream(srv *Server, ctx context.Context, req *Message, ...) (err error)

+ type ServerSideUploadState struct

+ func NewServerSideUploadState() *ServerSideUploadState

+ func (s *ServerSideUploadState) ReceiveFileInParts(req *Message, lastReply *Message) (err error)

Jan 5, 2025

Changes in this version

+ const UserMaxPayload

type Uploader

+ ReadCh <-chan *Message

Jan 5, 2025

Changes in this version

+ func MinimalBistreamFunc(srv *Server, ctx context.Context, req *Message, ...) (err error)

type BiServerState

+ func (bi *BiServerState) ServeBistream(srv *Server, ctx context.Context, req *Message, ...) (err error)

type HDR

+ UploadsCh chan *Message

Jan 4, 2025

Changes in this version

+ var ErrMagicWrong = fmt.Errorf("error: magic bytes not found at start of message")

+ var ErrTooLarge = fmt.Errorf(...)

Jan 4, 2025

Changes in this version

type Server

+ func (s *Server) RegisterBistreamFunc(name string, callme BistreamFunc)

Jan 4, 2025

Changes in this version

+ var ErrContextCancelled = fmt.Errorf("context cancelled")

Jan 4, 2025

Changes in this version

+ var ErrAlreadyDone = fmt.Errorf("Uploader has already been marked done. No more sending is allowed.")

+ var ErrWrongCallTypeForSendMessage = fmt.Errorf(...)

+ func NewCallID() string

+ type BiServerState struct

+ func (bi *BiServerState) ServerBistream(srv *Server, ctx context.Context, req *Message, ...) (err error)

+ type BistreamFunc func(srv *Server, ctx context.Context, req *Message, ...) (err error)

+ type Bistreamer struct

+ Name string

+ ReadCh <-chan *Message

+ Seqno uint64

+ WriteCh chan<- *Message

+ func (s *Bistreamer) CallID() string

+ func (s *Bistreamer) UploadMore(ctx context.Context, msg *Message, last bool) (err error)

type CallType

+ const CallDownloadBegin

+ const CallDownloadEnd

+ const CallDownloadMore

+ const CallRPCReply

+ const CallRequestBistreaming

+ const CallRequestDownload

+ const CallUploadBegin

+ const CallUploadEnd

+ const CallUploadMore

+ func (ct CallType) String() string

type Client

+ func (c *Client) GetReadIncomingChForCallID(callID string) (ch chan *Message)

+ func (c *Client) GetReadsForCallID(ch chan *Message, callID string)

+ func (c *Client) RequestBistreaming(ctx context.Context, bistreamerName string, req *Message) (b *Bistreamer, err error)

+ func (c *Client) RequestDownload(ctx context.Context, streamerName string) (downloader *Downloader, err error)

+ func (c *Client) UploadBegin(ctx context.Context, msg *Message) (strm *Uploader, err error)

+ type Downloader struct

+ CallID string

+ Name string

+ ReadCh chan *Message

+ Seqno uint64

type HDR

+ StreamPart int64

type Server

+ func (s *Server) RegisterBiFunc(name string, callme BistreamFunc)

+ func (s *Server) RegisterServerSendsDownloadFunc(name string, callme ServerSendsDownloadFunc)

+ func (s *Server) RegisterUploadReaderFunc(callmeUploadReader UploadReaderFunc)

+ func (s *Server) SendOneWayMessage(msg *Message, errWriteDur *time.Duration) error

+ type ServerSendsDownloadFunc func(srv *Server, ctx context.Context, req *Message, ...) (err error)

+ type ServerSendsDownloadState struct

+ func (ssss *ServerSendsDownloadState) ServerSendsDownload(srv *Server, ctx context.Context, req *Message, ...) (err error)

+ type ServerSideUploadFunc struct

+ func NewServerSideUploadFunc() *ServerSideUploadFunc

+ func (s *ServerSideUploadFunc) ReceiveFileInParts(req *Message, lastReply *Message) (err error)

+ type UploadReaderFunc func(req *Message, lastReply *Message) error

+ type Uploader struct

+ func (s *Uploader) CallID() string

+ func (s *Uploader) UploadMore(ctx context.Context, msg *Message, last bool) (err error)

Dec 29, 2024

Changes in this version

+ func ContextWithHDR(ctx context.Context, hdr *HDR) context.Context

type HDR

+ func HDRFromContext(ctx context.Context) (*HDR, bool)

Dec 29, 2024

Changes in this version

type Client

+ func (c *Client) SendAndGetReplyWithCtx(ctx context.Context, req *Message) (reply *Message, err error)

type HDR

+ Deadline time.Time

Dec 28, 2024

Changes in this version

+ var ErrCancelReqSent = fmt.Errorf("cancellation request sent")

type CallType

+ const CallCancelPrevious

type HDR

+ Ctx context.Context

+ type MustBeCancelled struct

+ Placeholder int

+ func NewMustBeCancelled() *MustBeCancelled

+ func (s *MustBeCancelled) MessageAPI_HangUntilCancel(req, reply *Message) error

+ func (s *MustBeCancelled) WillHangUntilCancel(ctx context.Context, args *Args, reply *Reply) error

+ func (z *MustBeCancelled) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MustBeCancelled) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *MustBeCancelled) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z MustBeCancelled) EncodeMsg(en *msgp.Writer) (err error)

+ func (z MustBeCancelled) MarshalMsg(b []byte) (o []byte, err error)

+ func (z MustBeCancelled) Msgsize() (s int)

Dec 7, 2024

Changes in this version

+ func PactDecrypt(symkey, assocData, nonce, tag []byte)

+ func PactEncrypt(symkey, assocData, nonce, tag []byte)

Dec 6, 2024

Changes in this version

type Message

+ func (m *Message) AsJSON(scratch []byte) (o []byte, err error)

Nov 17, 2024

Changes in this version

+ var ErrDone2 = fmt.Errorf("done channel closed 2")

+ func GoroNumber() int

type HDR

+ LocalRecvTm time.Time

Nov 12, 2024

Changes in this version

type Message

+ LocalErr error

Nov 12, 2024

Changes in this version

type Config

+ ReportStats int64

Nov 9, 2024

Changes in this version

type Config

+ HTTPConnectRequired bool

type NetConnWrapper

+ func (w *NetConnWrapper) Close() error

type Server

+ func (server *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

Nov 6, 2024

Changes in this version

+ func IsNil(face interface{}) bool

Nov 6, 2024

Changes in this version

+ var ErrTimeout = fmt.Errorf("time-out waiting for call to complete")

Nov 6, 2024

Changes in this version

+ type BenchmarkMessage struct

+ Field1 string

+ Field100 int32

+ Field101 int32

+ Field102 string

+ Field103 string

+ Field104 int32

+ Field12 bool

+ Field128 int32

+ Field129 string

+ Field13 bool

+ Field130 int32

+ Field131 int32

+ Field14 bool

+ Field150 int32

+ Field16 int32

+ Field17 bool

+ Field18 string

+ Field2 int32

+ Field22 int64

+ Field23 int32

+ Field24 bool

+ Field25 int32

+ Field271 int32

+ Field272 int32

+ Field280 int32

+ Field29 int32

+ Field3 int32

+ Field30 bool

+ Field4 string

+ Field5 []uint64

+ Field59 bool

+ Field6 int32

+ Field60 int32

+ Field67 int32

+ Field68 int32

+ Field7 string

+ Field78 bool

+ Field80 bool

+ Field81 bool

+ Field9 string

+ func (z *BenchmarkMessage) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BenchmarkMessage) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *BenchmarkMessage) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *BenchmarkMessage) Msgsize() (s int)

+ func (z *BenchmarkMessage) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *BenchmarkMessage) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ type Hello struct

+ Placeholder int

+ func (z *Hello) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Hello) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Hello) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z Hello) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Hello) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Hello) Msgsize() (s int)

Nov 6, 2024

Changes in this version

+ type CallType int

+ const CallKeepAlive

+ const CallNetRPC

+ const CallNone

+ const CallOneWay

+ const CallRPC

+ func (z *CallType) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *CallType) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *CallType) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z CallType) EncodeMsg(en *msgp.Writer) (err error)

+ func (z CallType) MarshalMsg(b []byte) (o []byte, err error)

+ func (z CallType) Msgsize() (s int)

type HDR

+ Typ CallType

Nov 2, 2024

Changes in this version

type Client

+ func (c *Client) Start() error

Oct 31, 2024

Changes in this version

+ type VerifiedHandshake struct

+ EphemPubKey []byte

+ SignatureOfEphem []byte

+ SigningCert []byte

+ func (z *VerifiedHandshake) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *VerifiedHandshake) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *VerifiedHandshake) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *VerifiedHandshake) Msgsize() (s int)

+ func (z *VerifiedHandshake) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *VerifiedHandshake) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

Oct 30, 2024

Changes in this version

+ type Args struct

+ A int

+ B int

+ func (z *Args) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Args) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Args) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z Args) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Args) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Args) Msgsize() (s int)

+ type Arith int

+ func (t *Arith) Add(args Args, reply *Reply) error

+ func (t *Arith) Div(args Args, reply *Reply) error

+ func (t *Arith) Error(args *Args, reply *Reply) error

+ func (t *Arith) Mul(args *Args, reply *Reply) error

+ func (t *Arith) Scan(args string, reply *Reply) (err error)

+ func (t *Arith) SleepMilli(args *Args, reply *Reply) error

+ func (t *Arith) String(args *Args, reply *string) error

+ func (z *Arith) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Arith) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Arith) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z Arith) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Arith) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Arith) Msgsize() (s int)

+ type BuiltinTypes struct

+ Placeholder int

+ func (BuiltinTypes) Array(args *Args, reply *[2]int) error

+ func (BuiltinTypes) Map(args *Args, reply *map[int]int) error

+ func (BuiltinTypes) Slice(args *Args, reply *[]int) error

+ func (BuiltinTypes) WantsContext(ctx context.Context, args *Args, reply *[2]int) error

+ func (z *BuiltinTypes) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BuiltinTypes) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *BuiltinTypes) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z BuiltinTypes) EncodeMsg(en *msgp.Writer) (err error)

+ func (z BuiltinTypes) MarshalMsg(b []byte) (o []byte, err error)

+ func (z BuiltinTypes) Msgsize() (s int)

+ type Embed struct

+ func (z *Embed) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Embed) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Embed) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z Embed) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Embed) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Embed) Msgsize() (s int)

+ type Green interface

+ type InvalidRequest struct

+ Placeholder int

+ func (z *InvalidRequest) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *InvalidRequest) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *InvalidRequest) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z InvalidRequest) EncodeMsg(en *msgp.Writer) (err error)

+ func (z InvalidRequest) MarshalMsg(b []byte) (o []byte, err error)

+ func (z InvalidRequest) Msgsize() (s int)

+ type Reply struct

+ C int

+ func (z *Reply) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Reply) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Reply) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z Reply) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Reply) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Reply) Msgsize() (s int)

+ type Simple int

+ func (t *Simple) Exported(args Args, reply *Reply) error

+ func (z *Simple) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Simple) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Simple) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z Simple) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Simple) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Simple) Msgsize() (s int)

Oct 28, 2024

Changes in this version

type Config

+ ClientSendKeepAlive time.Duration

Oct 27, 2024

Changes in this version

type Client

+ func (c *Client) IsDown() (down bool)

type Config

+ ServerSendKeepAlive time.Duration

type HDR

+ IsKeepAlive bool

Oct 27, 2024

Changes in this version

type Config

+ NoSharePortQUIC bool

+ type ServerClient struct

+ GoneCh chan struct{}

+ Remote string

Oct 19, 2024

Changes in this version

+ func NewChaCha20CryptoRandKey() []byte

Oct 18, 2024

Changes in this version

+ func NewXChaCha20CryptoRandKey() []byte

Oct 17, 2024

Changes in this version

type Config

+ func (cfg *Config) Clone() *Config

Oct 17, 2024

Changes in this version

+ var ErrNetRpcShutdown = errors.New("connection is shut down")

Oct 17, 2024

Changes in this version

+ var ErrTooLong = fmt.Errorf(...)

type Config

+ PreSharedKeyPath string

Oct 16, 2024

Changes in this version

+ var ErrHandshakeQUIC = fmt.Errorf("quic handshake failure")

Oct 15, 2024

Changes in this version

+ const DefaultDebugPath

+ const DefaultRPCPath

+ var DefaultNetServer = NewNetServer()

+ var ErrIsShutdown = errors.New("connection is shut down")

+ func Accept(lis net.Listener)

+ func HandleHTTP()

+ func Register(rcvr any) error

+ func RegisterName(name string, rcvr any) error

+ func ServeCodec(codec ServerCodec)

+ func ServeConn(conn io.ReadWriteCloser)

+ func ServeRequest(codec ServerCodec) error

+ type Call struct

+ Args any

+ Done chan *Call

+ Error error

+ Reply any

+ ServiceMethod string

type Client

+ func (c *Client) Call(serviceMethod string, args any, reply any) error

+ func (c *Client) Go(serviceMethod string, args any, reply any, done chan *Call) *Call

+ type ClientCodec interface

+ Close func() error

+ ReadResponseBody func(any) error

+ ReadResponseHeader func(*Response) error

+ WriteRequest func(*Request, any) error

+ type HDR struct

+ CallID string

+ Created string

+ From string

+ IsLeg2 bool

+ IsNetRPC bool

+ IsRPC bool

+ Nc net.Conn

+ PID int64

+ Seqno uint64

+ Serial int64

+ Subject string

+ To string

+ func HDRFromBytes(jsonData []byte) (*HDR, error)

+ func HDRFromGreenpack(header []byte) (*HDR, error)

+ func HDRFromOpaqueURLFriendly(s string) (*HDR, error)

+ func NewHDR(from, to, subject string, isRPC bool, isLeg2 bool) (m *HDR)

+ func (a *HDR) Equal(b *HDR) bool

+ func (m *HDR) Bytes() []byte

+ func (m *HDR) Compact() string

+ func (m *HDR) JSON() []byte

+ func (m *HDR) OpaqueURLFriendly() string

+ func (m *HDR) Pretty() string

+ func (m *HDR) String() string

+ func (mid *HDR) AsGreenpack(scratch []byte) (o []byte, err error)

+ func (z *HDR) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HDR) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *HDR) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *HDR) Msgsize() (s int)

+ func (z *HDR) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *HDR) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

type Message

+ HDR HDR

+ type NetClient struct

+ func Dial(network, address string) (*NetClient, error)

+ func DialHTTP(network, address string) (*NetClient, error)

+ func DialHTTPPath(network, address, path string) (*NetClient, error)

+ func NewNetClient(conn io.ReadWriteCloser) *NetClient

+ func NewNetClientWithCodec(codec ClientCodec) *NetClient

+ func (client *NetClient) Call(serviceMethod string, args any, reply any) error

+ func (client *NetClient) Close() error

+ func (client *NetClient) Go(serviceMethod string, args any, reply any, done chan *Call) *Call

+ type NetServer struct

+ func NewNetServer() *NetServer

+ func (server *NetServer) Accept(lis net.Listener)

+ func (server *NetServer) HandleHTTP(rpcPath, debugPath string)

+ func (server *NetServer) Register(rcvr any) error

+ func (server *NetServer) RegisterName(name string, rcvr any) error

+ func (server *NetServer) ServeCodec(codec ServerCodec)

+ func (server *NetServer) ServeConn(conn io.ReadWriteCloser)

+ func (server *NetServer) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (server *NetServer) ServeRequest(codec ServerCodec) error

+ type Request struct

+ Seq uint64

+ ServiceMethod string

+ func (z *Request) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Request) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Request) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z Request) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Request) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Request) Msgsize() (s int)

+ type Response struct

+ Error string

+ Seq uint64

+ ServiceMethod string

+ func (z *Response) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Response) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Response) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z Response) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Response) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Response) Msgsize() (s int)

type Server

+ func (s *Server) Register(rcvr any) error

+ func (s *Server) RegisterName(name string, rcvr any) error

+ type ServerCodec interface

+ Close func() error

+ ReadRequestBody func(any) error

+ ReadRequestHeader func(*Request) error

+ WriteResponse func(*Response, any) error

+ type ServerError string

+ func (e ServerError) Error() string

Oct 15, 2024

Changes in this version

type Client

+ func (c *Client) Name() string

+ type OneWayFunc func(req *Message)

type Server

+ func (s *Server) Register1Func(callme1 OneWayFunc)

+ func (s *Server) Register2Func(callme2 TwoWayFunc)

+ type TwoWayFunc func(req *Message, reply *Message)

Oct 12, 2024

Changes in this version

type Message

+ JobErrs string

+ func (m *Message) AsGreenpack(scratch []byte) (o []byte, err error)

Oct 12, 2024

Changes in this version

+ type ByteSlice []byte

+ func (z *ByteSlice) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ByteSlice) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *ByteSlice) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z ByteSlice) EncodeMsg(en *msgp.Writer) (err error)

+ func (z ByteSlice) MarshalMsg(b []byte) (o []byte, err error)

+ func (z ByteSlice) Msgsize() (s int)

type Message

+ JobErr string

+ func MessageFromGreenpack(r io.Reader) (*Message, error)

+ func (msg *Message) WriteAsGreenpack(w io.Writer, scratch []byte) error

Oct 12, 2024

Changes in this version

type Message

+ func (z *Message) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Message) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Message) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Message) Msgsize() (s int)

+ func (z *Message) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Message) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

Oct 12, 2024

Changes in this version

type Config

+ ClientDialToHostPort string

+ ClientKeyPairName string

+ ServerKeyPairName string

Oct 11, 2024

Changes in this version

type Client

+ func (c *Client) SetLocalAddr(local string)

Oct 11, 2024

Changes in this version

type Config

+ ClientHostPort string

+ func NewConfig() *Config

+ type SharedTransport struct

Oct 10, 2024

Changes in this version

+ func IsLocalhost(ipStr string) (isLocal bool, hostOnlyNoPort string)

Oct 10, 2024

Changes in this version

+ func LocalAddrMatching(addr string) (local string, err error)

+ func WrapWithBrackets(local string) string

type MID

+ Seqno uint64

Oct 10, 2024

Changes in this version

type Client

+ QuicConn quic.Connection

+ func (c *Client) RunQUIC(quicServerAddr string, tlsConfig *tls.Config)

type Config

+ UseQUIC bool

+ type NetConnWrapper struct

+ type QUIC_RWPair struct

+ Stream quic.Stream

type Server

+ func (s *Server) NewQUIC_RWPair(stream quic.Stream, conn quic.Connection) *QUIC_RWPair

+ func (s *Server) RunQUICServer(serverAddr string, tlsConfig *tls.Config, boundCh chan net.Addr)

Oct 10, 2024

Changes in this version

+ func SelfyNewKey(createKeyPairNamed, odir string) error

Oct 9, 2024

Changes in this version

+ const RFC3339MsecTz0

+ const RFC3339NanoNumericTZ0pad

+ const VersionByteBase59Checked

+ var Chicago *time.Location

+ var ErrDone = fmt.Errorf("done channel closed")

+ var ErrNetConnectionNotFound = fmt.Errorf("error: net.Conn not found")

+ var ErrNotFound = fmt.Errorf("known_tls_hosts file not found")

+ var ErrPubKeyMismath = fmt.Errorf("remote host pubkey does not match that on file!")

+ var ErrPubKeyUnknown = fmt.Errorf("remote host pubkey is not on file, and TOFU is off!")

+ var ErrShutdown = fmt.Errorf("shutting down")

+ var ForceQuiet = false

+ var Frankfurt *time.Location

+ var GTZ *time.Location

+ var London *time.Location

+ var MyPid = os.Getpid()

+ var NYC *time.Location

+ var OurStdout io.Writer = os.Stdout

+ var ShowPid bool

+ var UtcTz *time.Location

+ var Verbose bool = false

+ var VerboseVerbose bool = false

+ func AlwaysPrintf(format string, a ...interface{})

+ func Caller(upStack int) string

+ func DirExists(name string) bool

+ func FileExists(name string) bool

+ func FileLine(depth int) string

+ func FileSize(name string) (int64, error)

+ func GenAddress() string

+ func GetAvailPort() int

+ func GetExternalIP() string

+ func GetExternalIPAsInt() int

+ func HostKeyVerifies(knownKeysPath string, connState *tls.ConnectionState, remoteAddr string) (good, bad []string, wasNew bool, err0 error)

+ func IsRoutableIPv4(ip string) bool

+ func IsWritable(path string) bool

+ func LoadClientTLSConfig(embedded bool, sslCA, sslCert, sslCertKey string) (*tls.Config, error)

+ func LoadClientTLSConfigFilesystem(sslCA, sslCert, sslCertKey string) (*tls.Config, error)

+ func LoadServerTLSConfig(embedded bool, sslCA, sslClientCA, sslCert, sslCertKey string) (*tls.Config, error)

+ func LoadServerTLSConfigFilesystem(sslCA, sslClientCA, sslCert, sslCertKey string) (*tls.Config, error)

+ func P(format string, a ...interface{})

+ func PB(w io.Writer, format string, a ...interface{})

+ func PP(format string, a ...interface{})

+ func PPP(format string, a ...interface{})

+ func Printf(format string, a ...interface{}) (n int, err error)

+ func QPrintf(format string, a ...interface{}) (n int, err error)

+ func StripNanomsgAddressPrefix(nanomsgAddr string) (suffix string, err error)

+ func TSPrintf(format string, a ...interface{})

+ func VPrintf(format string, a ...interface{}) (n int, err error)

+ func VV(format string, a ...interface{})

+ func WaitUntilCanConnect(addr string)

+ type CallbackFunc func(in *Message) (out *Message)

+ type Client struct

+ Conn net.Conn

+ Connected chan error

+ func NewClient(name string, config *Config) (c *Client, err error)

+ func (c *Client) Close() error

+ func (c *Client) Err() error

+ func (c *Client) GetOneRead(seqno uint64, ch chan *Message)

+ func (c *Client) GetReadIncomingCh() (ch chan *Message)

+ func (c *Client) GetReads(ch chan *Message)

+ func (c *Client) LocalAddr() string

+ func (c *Client) OneWaySend(msg *Message, doneCh <-chan struct{}) (err error)

+ func (c *Client) RunClientMain(serverAddr string, tcp_only bool, certPath string)

+ func (c *Client) RunClientTCP(serverAddr string)

+ func (c *Client) RunReadLoop(conn net.Conn)

+ func (c *Client) RunSendLoop(conn net.Conn)

+ func (c *Client) SendAndGetReply(req *Message, doneCh <-chan struct{}) (reply *Message, err error)

+ func (c *Client) SendAndGetReplyWithTimeout(timeout time.Duration, req *Message) (reply *Message, err error)

+ func (c *Client) UngetReads(ch chan *Message)

+ type Config struct

+ CertPath string

+ ConnectTimeout time.Duration

+ KeyPairName string

+ LocalAddress string

+ ReadTimeout time.Duration

+ ServerAddr string

+ SkipVerifyKeys bool

+ TCPonly_no_TLS bool

+ WriteTimeout time.Duration

+ type Known struct

+ Hosts []*KnownKey

+ Path string

+ PubKeyMap map[string]*KnownKey

+ func NewKnown(path string) *Known

+ func (k *Known) Add(kh *KnownKey)

+ func (k *Known) WriteOut() (err error)

+ type KnownKey struct

+ Addr string

+ Emails string

+ KeyType string

+ Line int

+ PubKey string

+ func (kh *KnownKey) IdentityString() string

+ func (kh *KnownKey) String() string

+ type MID struct

+ CallID string

+ Created string

+ From string

+ IsLeg2 bool

+ IsRPC bool

+ PID int64

+ Serial int64

+ Subject string

+ To string

+ func MIDFromBytes(jsonData []byte) (*MID, error)

+ func MIDFromGreenpack(header []byte) (*MID, error)

+ func MIDFromOpaqueURLFriendly(s string) (*MID, error)

+ func NewMID(from, to, subject string, isRPC bool, isLeg2 bool) (m *MID)

+ func Unbytes(jsonData []byte) *MID

+ func (a *MID) Equal(b *MID) bool

+ func (m *MID) Bytes() []byte

+ func (m *MID) Compact() string

+ func (m *MID) JSON() []byte

+ func (m *MID) OpaqueURLFriendly() string

+ func (m *MID) Pretty() string

+ func (m *MID) String() string

+ func (mid *MID) AsGreenpack(scratch []byte) (o []byte, err error)

+ func (z *MID) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MID) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MID) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MID) Msgsize() (s int)

+ func (z *MID) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *MID) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ type Message struct

+ DoneCh chan *Message

+ Err error

+ JobSerz []byte

+ MID MID

+ Nc net.Conn

+ Seqno uint64

+ Subject string

+ func NewMessage() *Message

+ func NewMessageFromBytes(by []byte) (msg *Message)

+ func (msg *Message) String() string

+ type RWPair struct

+ Conn net.Conn

+ SendCh chan *Message

+ Server *Server

+ type Server struct

+ RemoteConnectedCh chan string

+ func NewServer(config *Config) *Server

+ func (s *Server) Close() error

+ func (s *Server) NewRWPair(conn net.Conn) *RWPair

+ func (s *Server) RegisterFunc(callme CallbackFunc)

+ func (s *Server) RunServerMain(serverAddress string, tcp_only bool, certPath string, boundCh chan net.Addr)

+ func (s *Server) RunTCP(serverAddress string, boundCh chan net.Addr)

+ func (s *Server) SendMessage(callID, subject, destAddr string, by []byte, seqno uint64) error

+ func (s *Server) Start() (serverAddr net.Addr, err error)