natStatus

Documentation

Index

• type NatsStatus
  • func (e *NatsStatus) DeleteKey(key string)
  • func (e *NatsStatus) Get(key string) (status *commomTypes.Status)
  • func (e *NatsStatus) GetAll(keyList []string) (statusOnLineList []*commomTypes.Status, usersIDOffLineList []string)
  • func (e *NatsStatus) GetAllCache() (cache []byte)
  • func (e *NatsStatus) GetKeys() (keyList []string)
  • func (e *NatsStatus) Invalidate(key string)
  • func (e *NatsStatus) InvalidateSync(subject string, data []byte) (err error)
  • func (e *NatsStatus) New(uid interfaces.UniqueID, queue interfaces.Queue, ...) (object interface{}, err error)
  • func (e *NatsStatus) Set(key string, status *commomTypes.Status, sync bool)
  • func (e *NatsStatus) SetAllCache(statusList map[string]*commomTypes.Status)
  • func (e *NatsStatus) SetSync(subject string, data []byte) (err error)

Types

type NatsStatus

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

func (*NatsStatus) DeleteKey

func (e *NatsStatus) DeleteKey(key string)

DeleteKey (Português): apaga uma chave do mapa

key: id do usuário a ser apagado da cache

func (*NatsStatus) Get

func (e *NatsStatus) Get(key string) (status *commomTypes.Status)

Get (Português): recupera o valor de status a partir da cheve informada

key: id do usuário a ser recuperado o status

func (*NatsStatus) GetAll

func (e *NatsStatus) GetAll(keyList []string) (statusOnLineList []*commomTypes.Status, usersIDOffLineList []string)

GetAll (Português): recupera todos os status a partir de uma lista de chaves

keyList: lista de ids de usuários a serem recuperados

func (*NatsStatus) GetAllCache

func (e *NatsStatus) GetAllCache() (cache []byte)

GetAllCache (Português): retorna um json com toda a cache de status

func (*NatsStatus) GetKeys

func (e *NatsStatus) GetKeys() (keyList []string)

GetKeys (Português): retorna todas as chaves contidas na lista de status

func (*NatsStatus) Invalidate

func (e *NatsStatus) Invalidate(key string)

Invalidate (Português): apaga uma chave ou a cache inteira, de acordo com o valor recebido

key: id do usuário a ser apagado da cache

func (*NatsStatus) InvalidateSync

func (e *NatsStatus) InvalidateSync(subject string, data []byte) (err error)

InvalidateSync (Português): recebe uma chave da fila para que a mesma seja apagada

subject: nome do canal
data: dado contido na fila

func (*NatsStatus) New

func (e *NatsStatus) New(uid interfaces.UniqueID, queue interfaces.Queue, channelStatusSet, channelInvalidateAll string) (object interface{}, err error)

New (Português): fábrica do objeto

uid: objeto compatível com a interface UniqueID inicializado
queue: objeto compatível com a interface Queue inicializado
channelStatusSet: nome do canal usado quando um novo status é definido
channelInvalidateAll: nome do canal usado quando um status é apagado

func (*NatsStatus) Set

func (e *NatsStatus) Set(key string, status *commomTypes.Status, sync bool)

Set (Português): adiciona um novo status

key: ID do usuário
status: ponteiro para o valor do status
sync: true, dispara um evento na fila

func (*NatsStatus) SetAllCache

func (e *NatsStatus) SetAllCache(statusList map[string]*commomTypes.Status)

SetAllCache (Português): apaga a cache anterior e popula a mesma

statusList: valor da nova cache

func (*NatsStatus) SetSync

func (e *NatsStatus) SetSync(subject string, data []byte) (err error)

SetSync (Português): recebe um status da fila e processa o valor

subject: nome do canal
data: dado contido na fila