listener

Documentation

Overview

Package listener implements the support for incoming TCP connections.

Index

• type Listener
  • func New(cfg *config.Config, inCh chan<- *commands.CommandRequest, id uint64, ...) (*Listener, error)
  • func (l *Listener) FinalizeStartup()
  • func (l *Listener) Halt()
  • func (l *Listener) RegisterDefaultIssuerHandlers()
  • func (l *Listener) RegisterDefaultServiceProviderHandlers()
  • func (l *Listener) RegisterHandler(o interface{}, hf requesthandler.ResolveRequestHandlerFunc)

Types

type Listener

type Listener struct {
	sync.Mutex
	worker.Worker
	// contains filtered or unexported fields
}

Listener represents the Coconut Server listener (listening on TCP socket, not for gRPC via HTTP2) TODO: remove old fields and make more generic

func New

func New(cfg *config.Config, inCh chan<- *commands.CommandRequest, id uint64, l *logger.Logger, addr string,
) (*Listener, error)

New creates a new listener.

func (*Listener) FinalizeStartup

func (l *Listener) FinalizeStartup()

FinalizeStartup is used when the server is a provider. It indicates it has aggregated required number of verification keys and hence can verify received credentials. TODO: get rid in favour of simply loading all keys on startup

func (*Listener) Halt

func (l *Listener) Halt()

Halt stops the listener and closes (if any) connections.

func (*Listener) RegisterDefaultIssuerHandlers

func (l *Listener) RegisterDefaultIssuerHandlers()

func (*Listener) RegisterDefaultServiceProviderHandlers

func (l *Listener) RegisterDefaultServiceProviderHandlers()

func (*Listener) RegisterHandler

func (l *Listener) RegisterHandler(o interface{}, hf requesthandler.ResolveRequestHandlerFunc)