session_registry

Documentation

Index

• Variables
• type CachedSessionRegistryService
  • func NewCachedSessionRegistryService(poktClient pokt_v0.PocketService, ...) *CachedSessionRegistryService
  • func (c *CachedSessionRegistryService) GetNodesByChain(chainId string) []*qos_models.QosNode
  • func (c *CachedSessionRegistryService) GetNodesMap() ...
  • func (c *CachedSessionRegistryService) GetSession(req *models.GetSessionRequest) (*Session, error)
• type Session
• type SessionRegistryService

Variables

var (
	ErrRecentlyFailed = errors.New("dispatch recently failed, returning early")
)

Types

type CachedSessionRegistryService

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

func NewCachedSessionRegistryService

func NewCachedSessionRegistryService(poktClient pokt_v0.PocketService, appRegistry apps_registry.AppsRegistryService, sessionCache ttl_cache.TTLCacheService[string, *Session], nodeCache ttl_cache.TTLCacheService[qos_models.SessionChainKey, []*qos_models.QosNode], logger *zap.Logger) *CachedSessionRegistryService

func (*CachedSessionRegistryService) GetNodesByChain

func (c *CachedSessionRegistryService) GetNodesByChain(chainId string) []*qos_models.QosNode

func (*CachedSessionRegistryService) GetNodesMap

func (c *CachedSessionRegistryService) GetNodesMap() map[qos_models.SessionChainKey]*ttlcache.Item[qos_models.SessionChainKey, []*qos_models.QosNode]

func (*CachedSessionRegistryService) GetSession

func (c *CachedSessionRegistryService) GetSession(req *models.GetSessionRequest) (*Session, error)

type Session

type Session struct {
	IsValid       bool
	PocketSession *models.Session
	Nodes         []*qos_models.QosNode
}

type SessionRegistryService

type SessionRegistryService interface {
	GetSession(req *models.GetSessionRequest) (*Session, error)
	GetNodesMap() map[qos_models.SessionChainKey]*ttlcache.Item[qos_models.SessionChainKey, []*qos_models.QosNode]
	GetNodesByChain(chainId string) []*qos_models.QosNode
}