actionCache

Documentation

Index

• type ActionJob
  • func (aj *ActionJob) String() string
• type ActionResult
• type Actions
  • func NewActions(actions map[string][]string, logger zLogger.ZLogger) *Actions
  • func (a *Actions) Action(ap *mediaserverproto.ActionParam, domain string, actionTimeout time.Duration) (*mediaserverproto.Cache, error)
  • func (a *Actions) AddClient(name string, client *ClientEntry)
  • func (a *Actions) GetClient(name string) (*ClientEntry, bool)
  • func (a *Actions) GetParams(_type, action, domain string) ([]string, error)
  • func (a *Actions) IsEmpty() bool
  • func (a *Actions) RemoveClient(name string) error
  • func (a *Actions) Start() error
  • func (a *Actions) Stop() error
• type Cache
  • func NewCache(actionTimeout time.Duration, dbs map[string]mediaserverproto.DatabaseClient, ...) *Cache
  • func (c *Cache) Action(ap *mediaserverproto.ActionParam, domain string) (*mediaserverproto.Cache, error)
  • func (c *Cache) AddActions(typeActionsParams TypeActionParams, domains []string) error
  • func (c *Cache) AddClientEntry(typeActionsParams TypeActionParams, domains []string, name string, ...)
  • func (c *Cache) Close() error
  • func (c *Cache) GetAction(mediaType, action, domain string) (*Actions, bool)
  • func (c *Cache) GetActions(typeActions TypeAction, domains []string) (resultActions *Actions, resultOK bool)
  • func (c *Cache) GetAllActionParam() TypeActionParams
  • func (c *Cache) GetClientEntry(mediaType, action, domain, address string) (*ClientEntry, bool)
  • func (c *Cache) GetClientEntryByName(name string) (resultClient *ClientEntry, resultDomains []string, ...)
  • func (c *Cache) GetParams(mediaType string, action string) ([]string, error)
  • func (c *Cache) RemoveClientEntry(address string) error
  • func (c *Cache) SetAction(typeActionsParam TypeActionParams, domains []string, actionsObject *Actions)
• type ClientEntry
  • func NewClientEntry(name string, client mediaserverproto.ActionClient, closer io.Closer, ...) *ClientEntry
  • func (c *ClientEntry) Close() error
  • func (c *ClientEntry) RefreshTimeout(interval time.Duration)
  • func (c *ClientEntry) SetTimeout(expiration time.Time)
  • func (c *ClientEntry) Start(workers uint32, logger zLogger.ZLogger) error
• type CurrentActions
  • func NewCurrentActions() *CurrentActions
  • func (ca *CurrentActions) AddAction(id string) error
  • func (ca *CurrentActions) AddWaiter(id string, ch chan<- *ActionResult) error
  • func (ca *CurrentActions) GetWaiters(id string) []chan<- *ActionResult
  • func (ca *CurrentActions) HasAction(id string) bool
  • func (ca *CurrentActions) RemoveAction(id string) error
• type Queue
  • func NewQueue[V any](size int, logger zLogger.ZLogger) *Queue[V]
  • func (q *Queue[V]) AddSize(size int)
  • func (q *Queue[V]) Len() int
  • func (q *Queue[V]) Out() <-chan V
  • func (q *Queue[V]) Pop() (V, bool)
  • func (q *Queue[V]) Push(item V) bool
  • func (q *Queue[V]) SetSize(size int)
  • func (q *Queue[V]) Start()
  • func (q *Queue[V]) Stop()
• type TypeAction
  • func (ta TypeAction) Equals(ta2 TypeAction) bool
  • func (ta TypeAction) String() string
• type TypeActionParams
  • func (tap TypeActionParams) Equals(tap2 TypeActionParams) bool
  • func (tap TypeActionParams) GetTypeActions() TypeAction

Types

type ActionJob

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

func (*ActionJob) String

func (aj *ActionJob) String() string

type ActionResult

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

type Actions

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

func NewActions

func NewActions(actions map[string][]string, logger zLogger.ZLogger) *Actions

func (*Actions) Action

func (a *Actions) Action(ap *mediaserverproto.ActionParam, domain string, actionTimeout time.Duration) (*mediaserverproto.Cache, error)

func (*Actions) AddClient

func (a *Actions) AddClient(name string, client *ClientEntry)

func (*Actions) GetClient

func (a *Actions) GetClient(name string) (*ClientEntry, bool)

func (*Actions) GetParams

func (a *Actions) GetParams(_type, action, domain string) ([]string, error)

func (*Actions) IsEmpty

func (a *Actions) IsEmpty() bool

func (*Actions) RemoveClient

func (a *Actions) RemoveClient(name string) error

func (*Actions) Start

func (a *Actions) Start() error

func (*Actions) Stop

func (a *Actions) Stop() error

type Cache

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

func NewCache

func NewCache(actionTimeout time.Duration, dbs map[string]mediaserverproto.DatabaseClient, allDomains []string, logger zLogger.ZLogger) *Cache

func (*Cache) Action

func (c *Cache) Action(ap *mediaserverproto.ActionParam, domain string) (*mediaserverproto.Cache, error)

func (*Cache) AddActions

func (c *Cache) AddActions(typeActionsParams TypeActionParams, domains []string) error

func (*Cache) AddClientEntry

func (c *Cache) AddClientEntry(typeActionsParams TypeActionParams, domains []string, name string, client *ClientEntry)

func (*Cache) Close

func (c *Cache) Close() error

func (*Cache) GetAction

func (c *Cache) GetAction(mediaType, action, domain string) (*Actions, bool)

func (*Cache) GetActions

func (c *Cache) GetActions(typeActions TypeAction, domains []string) (resultActions *Actions, resultOK bool)

func (*Cache) GetAllActionParam

func (c *Cache) GetAllActionParam() TypeActionParams

func (*Cache) GetClientEntry

func (c *Cache) GetClientEntry(mediaType, action, domain, address string) (*ClientEntry, bool)

func (*Cache) GetClientEntryByName

func (c *Cache) GetClientEntryByName(name string) (resultClient *ClientEntry, resultDomains []string, resultTypeActions TypeAction, rok bool)

func (*Cache) GetParams

func (c *Cache) GetParams(mediaType string, action string) ([]string, error)

func (*Cache) RemoveClientEntry

func (c *Cache) RemoveClientEntry(address string) error

func (*Cache) SetAction

func (c *Cache) SetAction(typeActionsParam TypeActionParams, domains []string, actionsObject *Actions)

type ClientEntry

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

func NewClientEntry

func NewClientEntry(name string, client mediaserverproto.ActionClient, closer io.Closer, interval time.Duration, dbs map[string]mediaserverproto.DatabaseClient, queueSize int) *ClientEntry

func (*ClientEntry) Close

func (c *ClientEntry) Close() error

func (*ClientEntry) RefreshTimeout

func (c *ClientEntry) RefreshTimeout(interval time.Duration)

func (*ClientEntry) SetTimeout

func (c *ClientEntry) SetTimeout(expiration time.Time)

func (*ClientEntry) Start

func (c *ClientEntry) Start(workers uint32, logger zLogger.ZLogger) error

type CurrentActions

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

func NewCurrentActions

func NewCurrentActions() *CurrentActions

func (*CurrentActions) AddAction

func (ca *CurrentActions) AddAction(id string) error

func (*CurrentActions) AddWaiter

func (ca *CurrentActions) AddWaiter(id string, ch chan<- *ActionResult) error

func (*CurrentActions) GetWaiters

func (ca *CurrentActions) GetWaiters(id string) []chan<- *ActionResult

func (*CurrentActions) HasAction

func (ca *CurrentActions) HasAction(id string) bool

func (*CurrentActions) RemoveAction

func (ca *CurrentActions) RemoveAction(id string) error

type Queue

type Queue[V any] struct {
	sync.Mutex
	Items []*V
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue[V any](size int, logger zLogger.ZLogger) *Queue[V]

func (*Queue[V]) AddSize

func (q *Queue[V]) AddSize(size int)

func (*Queue[V]) Len

func (q *Queue[V]) Len() int

func (*Queue[V]) Out

func (q *Queue[V]) Out() <-chan V

func (*Queue[V]) Pop

func (q *Queue[V]) Pop() (V, bool)

func (*Queue[V]) Push

func (q *Queue[V]) Push(item V) bool

func (*Queue[V]) SetSize

func (q *Queue[V]) SetSize(size int)

func (*Queue[V]) Start

func (q *Queue[V]) Start()

func (*Queue[V]) Stop

func (q *Queue[V]) Stop()

type TypeAction

type TypeAction map[string][]string

func (TypeAction) Equals

func (ta TypeAction) Equals(ta2 TypeAction) bool

func (TypeAction) String

func (ta TypeAction) String() string

type TypeActionParams

type TypeActionParams map[string]map[string][]string

func (TypeActionParams) Equals

func (tap TypeActionParams) Equals(tap2 TypeActionParams) bool

func (TypeActionParams) GetTypeActions

func (tap TypeActionParams) GetTypeActions() TypeAction