types

Aug 18, 2024

Changes in this version

type Filter

+ func (f *Filter) String() string

+ func (f *Filter) ToSQL() (string, []interface{}, error)

Aug 18, 2024

Changes in this version

+ const MEMBER_STATUS_APPROVED

+ const MEMBER_STATUS_INVITED

+ const MEMBER_STATUS_REJECTED

+ const MEMBER_STATUS_REQUESTED

+ const ROLE_ADMIN

+ const ROLE_DEMO

+ const ROLE_USER

+ const ROLE_VIEWER

+ const USER_DEMO_ID

+ const USER_LOGR_ID

Aug 17, 2024

Changes in this version

type Sock

+ Conn io.WriteCloser

+ Session *SockSession

+ func (s *Sock) Delete() error

+ func (s *Sock) LoadSession()

+ func (s *Sock) SetStore(store SessionStore)

Aug 16, 2024

Changes in this version

+ type SessionStore interface

+ Del func(key string) error

+ Get func(key string) (*session, error)

+ Set func(key string, value *session) error

Aug 14, 2024

Changes in this version

+ const DASHBOARD_DEMO_ID

+ const DASHBOARD_SYSTEM_ID

+ const DASHKEY_DEMO_ID

+ const DASHKEY_SYSTEM_ID

+ type DashKeyMap map[int]*DashKey

type DashKeys

+ func (keys DashKeys) Get(id int) *DashKey

+ type DashMap map[int]*Dashboard

Aug 13, 2024

Changes in this version

+ type JwtService struct

+ func NewJwtService(jwtSecretFunc func() string) *JwtService

+ func (js *JwtService) ParseToken(token string) (*Claims, *jwt.Token, error)

+ func (js *JwtService) SignToken(claims *Claims) (string, error)

+ type LogPackageMeta struct

+ Protocol string

+ Size int

type SockMap

+ func NewSockMap() *SockMap

+ func (sm *SockMap) GetSock(userId int, sockId string) *Sock

+ func (sm *SockMap) GetSocks(userId int) *cmap.ConcurrentMap[string, *Sock]

+ func (sm *SockMap) Push(lg *_types.Log) int

+ func (sm *SockMap) Register(s *Sock)

+ func (sm *SockMap) SetSessionStore(store SockSessionStore)

+ func (sm *SockMap) String() string

+ func (sm *SockMap) Unregister(s *Sock)

type States

+ func NewStates() *States

Aug 10, 2024

Changes in this version

type LogPackageJoiner

+ func NewLogPackageJoiner(delay time.Duration, tries int) *LogPackageJoiner

Jul 30, 2024

Changes in this version

+ type MemorySessionStore struct

+ func (s MemorySessionStore) Del(key string) error

+ func (s MemorySessionStore) Get(key string) (*SockSession, error)

+ func (s MemorySessionStore) Set(key string, value *SockSession) error

+ type RedisSessionStore struct

+ func NewRedisSessionStore(addr string, db int, ttl time.Duration) (*RedisSessionStore, error)

+ func (store *RedisSessionStore) Del(key string) error

+ func (store *RedisSessionStore) Get(key string) (*SockSession, error)

+ func (store *RedisSessionStore) Set(key string, value *SockSession) error

type Sock

+ JwtToken string

+ func (s *Sock) HandleMessage(msg *SockMessage)

type SockCMap

+ func NewSockCMap() *SockCMap

+ func (sm *SockCMap) Push(log *_types.Log)

+ func (sm *SockCMap) Register(s *Sock)

+ func (sm *SockCMap) SetSessionStore(store SockSessionStore)

+ func (sm *SockCMap) Unregister(s *Sock)

+ type SockSession struct

+ Listeners map[string]int

+ Paused bool

+ type SockSessionStore interface

+ Del func(key string) error

+ Get func(key string) (*SockSession, error)

+ Set func(key string, value *SockSession) error

Mar 13, 2024

Changes in this version

type Claims

+ func (claims *Claims) ParseWithClaims(token string, secret string) (*jwt.Token, error)

type Sock

+ func (s *Sock) GetFilter() *Filter

+ func (s *Sock) HasListener(path string) bool

+ func (s *Sock) IsExpired() bool

+ func (s *Sock) IsPaused() bool

type States

+ func (s *States) Pop(state string) (string, bool)

+ func (s *States) Push(v string) string

+ func (s States) Init() *States

Mar 13, 2024

Changes in this version

+ type SockCMap struct

+ func (sm *SockCMap) Add(s *Sock)

+ func (sm *SockCMap) Delete(userId int, sockId string) bool

+ func (sm *SockCMap) GetSock(userId int, sockId string) *Sock

+ func (sm *SockCMap) GetSocks(userId int) *cmap.ConcurrentMap[string, *Sock]

+ func (sm *SockCMap) PushLog(lg *_types.Log) int

+ func (sm *SockCMap) SetFilter(userId int, sockId string, filter *Filter) bool

+ func (sm *SockCMap) SetPaused(userId int, sockId string, state bool) bool

+ func (sm *SockCMap) String() string

+ func (sm SockCMap) Init() *SockCMap

+ type UID int

+ func (id UID) String() string

Mar 9, 2024

Changes in this version

+ const UserDemoId

+ const UserLogrId

+ type CountVector _types.Count

+ func (c *CountVector) AsVector() []interface{}

type DashStatRow

+ Message string

Jan 22, 2024

Changes in this version

+ type LogPackageJoiner struct

+ Data map[string]LogPackageRow

+ func (m *LogPackageJoiner) Add(lp *_types.LogPackage, tries int) (complete bool, joined *_types.LogPackage)

+ func (m *LogPackageJoiner) Drop(uid string)

+ type LogPackageRow []*_types.LogPackage

+ func (chunks LogPackageRow) Joined() (complete bool, joined *_types.LogPackage)

Feb 10, 2023

Changes in this version

+ const DashboardDemoId

+ const DashboardSystemId

+ const MemberStatusApproved

+ const MemberStatusInvited

+ const MemberStatusRejected

+ const MemberStatusRequested

+ const ProviderGithub

+ const ProviderGoogle

+ const RoleAdmin

+ const RoleDemo

+ const RoleUser

+ const RoleViewer

+ type Avg struct

+ Num int

+ Sum float64

+ func (a *Avg) Value() float64

+ type Claims struct

+ AccessToken string

+ AccessTokenCipher string

+ GihubId int64

+ Id int

+ Role int

+ Username string

+ func (p *Claims) DecryptAccessToken() error

+ func (p *Claims) EncryptAccessToken() error

+ type Count struct

+ DashId int

+ Hostname string

+ Keyname string

+ Logname string

+ Timestamp int64

+ Version string

+ func (c *Count) AsVector() []interface{}

+ func (c *Count) Avg(num float64) *Count

+ func (c *Count) Decrypt(cipherText string, priv string) error

+ func (c *Count) Encrypt(priv string) (string, error)

+ func (c *Count) Inc(num float64) *Count

+ func (c *Count) Max(num float64) *Count

+ func (c *Count) Min(num float64) *Count

+ func (c *Count) Per(taken float64, total float64) *Count

+ func (c *Count) Time(duration time.Duration) func() time.Duration

+ type Counts []*Count

+ func (cs Counts) Format() Series

+ type DashKey struct

+ DashId int

+ Id int

+ Name string

+ PrivateKey string

+ PublicKey string

+ type DashKeys []*DashKey

+ type DashMember struct

+ DashId int

+ Id int

+ Status int

+ User *User

+ UserId int

+ type DashMembers []*DashMember

+ func (dm DashMembers) ApprovedOnly() DashMembers

+ func (dm DashMembers) DashIds() []int

+ func (ds DashMembers) ByDashId() map[int]*DashMember

+ func (ds DashMembers) ByUserId() map[int]*DashMember

+ func (ds DashMembers) HasDash(dashId int) *DashMember

+ func (ds DashMembers) HasUser(userId int) *DashMember

+ type DashStatRow struct

+ Cnt int

+ DashId int

+ Hostname string

+ Level string

+ Logname string

+ Updated int64

+ Version string

+ type DashStatRows []*DashStatRow

+ type Dashboard struct

+ Id int

+ Keys DashKeys

+ Members DashMembers

+ Name string

+ Owner *User

+ OwnerId int

+ type Dashboards []*Dashboard

+ func (ds Dashboards) ByPrimary() map[int]*Dashboard

+ func (ds Dashboards) Ids() []int

+ type Filter struct

+ DashId int

+ Hostname string

+ Keyname string

+ Level string

+ Limit int

+ Logname string

+ Message string

+ Offset int64

+ Pattern string

+ Pid int

+ Timestamp [2]int64

+ Version string

+ func (f *Filter) Match(log *Log) bool

+ func (f *Filter) ToSql() (string, []interface{}, error)

+ type Inc struct

+ Val float64

+ func (i *Inc) Value() float64

+ type Log struct

+ DashId int

+ Hostname string

+ Initiator string

+ Level string

+ Logname string

+ Message string

+ Pid int

+ Timestamp int64

+ Version string

+ func (log *Log) Decrypt(cipherText string, priv string) error

+ func (log *Log) Encrypt(priv string) (string, error)

+ type LogPackage struct

+ CipherCount string

+ CipherLog string

+ DashId int

+ PublicKey string

+ func (lp *LogPackage) DecryptCount(priv string) error

+ func (lp *LogPackage) DecryptLog(priv string) error

+ type Logs []*Log

+ type Max struct

+ Val float64

+ func (m *Max) Value() float64

+ type Metrics struct

+ func (m Metrics) ToMap() map[string]interface{}

+ type Min struct

+ Val float64

+ func (m *Min) Value() float64

+ type Per struct

+ Taken float64

+ Total float64

+ func (p *Per) Value() float64

+ type Serie struct

+ Data [][2]interface{}

+ Hostname string

+ Keyname string

+ Kind string

+ type Series []*Serie

+ type Sock struct

+ Listeners map[string]int

+ Paused bool

+ SockId string

+ func (s *Sock) AddListener(path string)

+ func (s *Sock) RemoveListener(path string)

+ func (s *Sock) SendLog(lg *Log) error

+ func (s *Sock) SetFilter(f *Filter)

+ func (s *Sock) SetPaused(state bool)

+ type SockMap struct

+ func (sm *SockMap) Delete(userId int, uid string) bool

+ func (sm *SockMap) Get(userId int, sockId string) *Sock

+ func (sm *SockMap) Info() string

+ func (sm *SockMap) PushLog(lg *Log) int

+ func (sm *SockMap) Set(s *Sock)

+ func (sm *SockMap) SetFilter(userId int, sockId string, filter *Filter) bool

+ func (sm *SockMap) SetPaused(userId int, sockId string, state bool) bool

+ type SockMessage struct

+ Action string

+ Path string

+ Payload interface{}

+ type States struct

+ Data map[string]string

+ func (s States) Get(state string) (string, bool)

+ func (s States) Insert(v string) string

+ func (s States) Set(k string, v string)

+ type Time struct

+ Duration int64

+ func (t *Time) Value() int64

+ type User struct

+ CreatedAt *time.Time

+ GithubId int64

+ Id int

+ LoginAt *time.Time

+ Role int

+ Username string

+ type Users []*User