server

Documentation

Index

• func Listen(ledger txstream.Ledger, bindAddress string, log *logger.Logger, ...) error
• func Run(conn net.Conn, log *logger.Logger, ledger txstream.Ledger, ...)
• type Connection

Functions

func Listen

func Listen(ledger txstream.Ledger, bindAddress string, log *logger.Logger, shutdownSignal <-chan struct{}) error

Listen starts a TCP listener and starts a Connection for each accepted connection.

func Run

func Run(conn net.Conn, log *logger.Logger, ledger txstream.Ledger, shutdownSignal <-chan struct{})

Run starts the server-side handling code for an already accepted connection from a client.

Types

type Connection

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

Connection handles the server-side part of the txstream protocol.