Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

flatend

package module

Go to main page

Versions in this module

v0

v0.1.1

Oct 19, 2020

v0.1.0

Oct 18, 2020

Changes in this version

type Context

+ func (c *Context) GetConn() *monte.Conn

type Node

+ func (n *Node) GetProvider(conn *monte.Conn) *Provider

type Provider

+ func (p *Provider) GetConn() *monte.Conn

+ func (p *Provider) GetID() *kademlia.ID

v0.0.9

Oct 18, 2020

Changes in this version

+ const ChunkSize

+ var ErrProviderNotAvailable = errors.New("provider unable to provide service")

+ func Addr(host net.IP, port uint16) string

+ func GenerateSecretKey() kademlia.PrivateKey

+ type Context struct

+ Body io.ReadCloser

+ Headers map[string]string

+ ID kademlia.ID

+ func (c *Context) Write(data []byte) (int, error)

+ func (c *Context) WriteHeader(key, val string)

+ type DataPacket struct

+ Data []byte

+ ID uint32

+ func UnmarshalDataPacket(buf []byte) (DataPacket, error)

+ func (p DataPacket) AppendTo(dst []byte) []byte

+ type Handler func(ctx *Context)

+ type HandshakePacket struct

+ ID *kademlia.ID

+ Services []string

+ Signature kademlia.Signature

+ func UnmarshalHandshakePacket(buf []byte) (HandshakePacket, error)

+ func (h HandshakePacket) AppendPayloadTo(dst []byte) []byte

+ func (h HandshakePacket) AppendTo(dst []byte) []byte

+ func (h HandshakePacket) Validate(dst []byte) error

+ type Node struct

+ BindAddrs []string

+ PublicAddr string

+ SecretKey kademlia.PrivateKey

+ Services map[string]Handler

+ func (n *Node) Bootstrap()

+ func (n *Node) HandleConnState(conn *monte.Conn, state monte.ConnState)

+ func (n *Node) HandleMessage(ctx *monte.Context) error

+ func (n *Node) Probe(addr string) error

+ func (n *Node) ProvidersFor(services ...string) []*Provider

+ func (n *Node) Push(services []string, headers map[string]string, body io.ReadCloser) (*Stream, error)

+ func (n *Node) Shutdown()

+ func (n *Node) Start(addrs ...string) error

+ type Opcode = uint8

+ const OpcodeData

+ const OpcodeFindNodeRequest

+ const OpcodeFindNodeResponse

+ const OpcodeHandshake

+ const OpcodeServiceRequest

+ const OpcodeServiceResponse

+ type Provider struct

+ func (p *Provider) Addr() string

+ func (p *Provider) Close()

+ func (p *Provider) CloseStreamWithError(stream *Stream, err error)

+ func (p *Provider) GetStream(id uint32) (*Stream, bool)

+ func (p *Provider) NextStream() *Stream

+ func (p *Provider) Push(services []string, headers map[string]string, body io.ReadCloser) (*Stream, error)

+ func (p *Provider) RegisterStream(header ServiceRequestPacket) (*Stream, bool)

+ func (p *Provider) Services() []string

+ type Providers struct

+ func NewProviders() *Providers

+ type ServiceRequestPacket struct

+ Headers map[string]string

+ ID uint32

+ Services []string

+ func UnmarshalServiceRequestPacket(buf []byte) (ServiceRequestPacket, error)

+ func (p ServiceRequestPacket) AppendTo(dst []byte) []byte

+ type ServiceResponsePacket struct

+ Handled bool

+ Headers map[string]string

+ ID uint32

+ func UnmarshalServiceResponsePacket(buf []byte) (ServiceResponsePacket, error)

+ func (p ServiceResponsePacket) AppendTo(dst []byte) []byte

+ type Stream struct

+ Header *ServiceResponsePacket

+ ID uint32

+ Reader *pipeReader

+ Writer *pipeWriter