connection

type Config struct {
	IPCheck   IPCheckConfig
	KeepAlive KeepAliveConfig
}

type ConnectOptions struct {
	ConsumerID      identity.Identity
	Proposal        proposal.PricedServiceProposal
	ProposalLookup  ProposalLookup
	SessionID       session.ID
	Params          ConnectParams
	SessionConfig   []byte
	ProviderNATConn *net.UDPConn
	ChannelConn     *net.UDPConn
	HermesID        common.Address
}

type ConnectParams struct {
	// kill switch option restricting communication only through VPN
	DisableKillSwitch bool
	// DNS servers to use
	DNS DNSOption

	ProxyPort int
}

type Connection interface {
	Start(context.Context, ConnectOptions) error
	Reconnect(context.Context, ConnectOptions) error
	Stop()
	GetConfig() (ConsumerConfig, error)
	State() <-chan connectionstate.State
	Statistics() (connectionstate.Statistics, error)
}

type ConnectionStart func(context.Context, ConnectOptions) error

type ConsumerConfig interface{}

type Creator func(serviceType string) (Connection, error)

type DNSOption string

type Factory func() (Connection, error)

type IPCheckConfig struct {
	MaxAttempts             int
	SleepDurationAfterCheck time.Duration
}

type KeepAliveConfig struct {
	SendInterval    time.Duration
	SendTimeout     time.Duration
	MaxSendErrCount int
}

type Manager interface {
	// Connect creates new connection from given consumer to provider, reports error if connection already exists
	Connect(consumerID identity.Identity, hermesID common.Address, proposal ProposalLookup, params ConnectParams) error
	// Status queries current status of connection
	Status() connectionstate.Status
	// Stats provides connection statistics information.
	Stats() connectionstate.Statistics
	// Disconnect closes established connection, reports error if no connection
	Disconnect() error
	// CheckChannel checks if current session channel is alive, returns error on failed keep-alive ping
	CheckChannel(context.Context) error
	// Reconnect reconnects current session
	Reconnect()
}

type MultiManager interface {
	// Connect creates new connection from given consumer to provider, reports error if connection already exists
	Connect(consumerID identity.Identity, hermesID common.Address, proposal ProposalLookup, params ConnectParams) error
	// Status queries current status of connection
	Status(n int) connectionstate.Status
	// Stats provides connection statistics information.
	Stats(n int) connectionstate.Statistics
	// Disconnect closes established connection, reports error if no connection
	Disconnect(n int) error
	// CheckChannel checks if current session channel is alive, returns error on failed keep-alive ping
	CheckChannel(context.Context) error
	// Reconnect reconnects current session
	Reconnect(n int)
}

type PaymentEngineFactory func(senderUUID string, channel p2p.Channel, consumer, provider identity.Identity, hermes common.Address, proposal proposal.PricedServiceProposal, price market.Price) (PaymentIssuer, error)

type PaymentIssuer interface {
	Start() error
	SetSessionID(string)
	Stop()
}

type PriceGetter interface {
	GetCurrentPrice(nodeType string, country string) (market.Price, error)
}

type ProposalLookup func() (proposal *proposal.PricedServiceProposal, err error)

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

type StateChannel chan connectionstate.State

type TimeGetter func() time.Time

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