service

type Cleaner struct {
	SessionStorage SessionStorage
}

type Config struct {
	KeepAlive KeepAliveConfig
}

type ConfigParams struct {
	SessionServiceConfig   ServiceConfiguration
	SessionDestroyCallback DestroyCallback
}

type ConfigProvider interface {
	ProvideConfig(sessionID string, sessionConfig json.RawMessage, conn *net.UDPConn) (*ConfigParams, error)
}

type DestroyCallback func()

type Discovery interface {
	Start(ownIdentity identity.Identity, proposal func() market.ServiceProposal)
	Stop()
	Wait()
}

type DiscoveryFactory func() Discovery

type FindOpts struct {
	Peer        *identity.Identity
	ServiceType string
}

type ID string

type IDGenerator func() (session.ID, error)

type Instance struct {
	ID ID

	ProviderID identity.Identity
	Type       string
	Options    Options

	Proposal market.ServiceProposal
	// contains filtered or unexported fields
}

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

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

type NATEventGetter interface {
	LastEvent() *event.Event
}

type Options interface{}

type PaymentEngine interface {
	Start() error
	WaitFirstInvoice(time.Duration) error
	Stop()
}

type PaymentEngineFactory func(providerID, consumerID identity.Identity, chainID int64, hermesID common.Address, sessionID string, exchangeChan chan crypto.ExchangeMessage, price market.Price) (PaymentEngine, error)

type Pool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type PriceValidator interface {
	IsPriceValid(in market.Price, nodeType string, country string, serviceType string) bool
}

type PromiseProcessor interface {
	Start(proposal market.ServiceProposal) error
	Stop() error
}

type Publisher interface {
	Publish(topic string, data interface{})
}

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

type RegistryFactory func(options Options) (Service, error)

type Service interface {
	Serve(instance *Instance) error
	Stop() error
	ConfigProvider
}

type ServiceConfiguration interface{}

type Session struct {
	ID               session.ID
	ConsumerID       identity.Identity
	ConsumerLocation market.Location
	HermesID         common.Address
	Proposal         market.ServiceProposal
	ServiceID        string
	CreatedAt        time.Time
	// contains filtered or unexported fields
}

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

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

type SessionStorage interface {
	RemoveForService(serviceID string)
}

type WaitForNATHole func() error