sessions

package

v0.0.0-...-26ee366 Latest Latest Go to latest Published: Aug 27, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitlab.com/mb-saces/pinecone

Links

Open Source Insights

Documentation ¶

Index ¶

type HTTP
- func (h *HTTP) Client() *http.Client
- func (h *HTTP) Mux() *http.ServeMux
type SessionProtocol
type Sessions
- func NewSessions(log types.Logger, r *router.Router, protos []string) *Sessions
- func (s *Sessions) Close() error
- func (s *Sessions) Protocol(proto string) *SessionProtocol
type Stream
- func (s *Stream) LocalAddr() net.Addr
- func (s *Stream) RemoteAddr() net.Addr

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type HTTP ¶

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

func (*HTTP) Client ¶

func (h *HTTP) Client() *http.Client

func (*HTTP) Mux ¶

func (h *HTTP) Mux() *http.ServeMux

type SessionProtocol ¶

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

func (*SessionProtocol) Accept ¶

func (s *SessionProtocol) Accept() (net.Conn, error)

Accept blocks until a new connection request is received. The connection returned by this function will be TLS-encrypted.

func (*SessionProtocol) Addr ¶

func (s *SessionProtocol) Addr() net.Addr

func (*SessionProtocol) Close ¶

func (s *SessionProtocol) Close() error

func (*SessionProtocol) Dial ¶

func (q *SessionProtocol) Dial(network, addr string) (net.Conn, error)

Dial dials a given public key using the supplied network. The address must be the destination public key specified in hex.

func (*SessionProtocol) DialContext ¶

func (s *SessionProtocol) DialContext(ctx context.Context, network, addrstr string) (net.Conn, error)

DialContext dials a given public key using the supplied network. The network field can be used to specify which routing algorithm to use for the connection: "ed25519+greedy" for greedy routing or "ed25519+source" for source routing - DHT lookups and pathfinds will be performed for these networks automatically. Otherwise, the default "ed25519" will use snake routing. The address must be the destination public key specified in hex. If the context expires then the connection will be torn down automatically.

func (*SessionProtocol) DialTLS ¶

func (q *SessionProtocol) DialTLS(network, addr string) (net.Conn, error)

DialTLS is an alias for Dial, as all sessions are TLS-encrypted.

func (*SessionProtocol) DialTLSContext ¶

func (q *SessionProtocol) DialTLSContext(ctx context.Context, network, addr string) (net.Conn, error)

DialTLSContext is an alias for DialContext, as all sessions are TLS-encrypted.

func (*SessionProtocol) HTTP ¶

func (q *SessionProtocol) HTTP() *HTTP

func (*SessionProtocol) Sessions ¶

func (s *SessionProtocol) Sessions() []ed25519.PublicKey

type Sessions ¶

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

func NewSessions ¶

func NewSessions(log types.Logger, r *router.Router, protos []string) *Sessions

func (*Sessions) Close ¶

func (s *Sessions) Close() error

func (*Sessions) Protocol ¶

func (s *Sessions) Protocol(proto string) *SessionProtocol

type Stream ¶

type Stream struct {
	quic.Stream
	// contains filtered or unexported fields
}

func (*Stream) LocalAddr ¶

func (s *Stream) LocalAddr() net.Addr

func (*Stream) RemoteAddr ¶

func (s *Stream) RemoteAddr() net.Addr

Source Files ¶

View all Source files

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