storage

package
v0.6.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 4, 2020 License: MIT Imports: 17 Imported by: 1

Documentation

Index

Constants

View Source 
const ChannelListUpdateInterval = time.Hour * 24
View Source 
const ChannelListUpdateTimeout = time.Minute * 5

Variables

View Source 
var (
	ErrInvalidCert      = errors.New("Invalid certificate")
	ErrCouldNotSaveCert = errors.New("Could not save certificate")
)
View Source 
var (
	ErrNotFound = errors.New("no item found")
)
View Source 
var Path directory

Functions

func DefaultDirectory 

func DefaultDirectory() string

func Initialize 

func Initialize(root, dataRoot, configRoot string)

Types

type Channel 

type Channel struct {
	Server string
	Name   string
	Topic  string
}

TODO: Remove topic from disk schema

func (*Channel) Marshal 

func (d *Channel) Marshal(buf []byte) ([]byte, error)

func (*Channel) Size 

func (d *Channel) Size() (s uint64)

func (*Channel) Unmarshal 

func (d *Channel) Unmarshal(buf []byte) (uint64, error)

type ChannelIndexManager added in v0.6.1 

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

func NewChannelIndexManager added in v0.6.1 

func NewChannelIndexManager() *ChannelIndexManager

func (*ChannelIndexManager) Get added in v0.6.1 

func (m *ChannelIndexManager) Get(server string) (ChannelListIndex, bool)

func (*ChannelIndexManager) Set added in v0.6.1 

func (m *ChannelIndexManager) Set(server string, index ChannelListIndex)

type ChannelListIndex added in v0.6.1 

type ChannelListIndex interface {
	Add(item *ChannelListItem)
	Finish()
	Search(q string) []*ChannelListItem
	SearchN(q string, start, n int) []*ChannelListItem
}

type ChannelListItem added in v0.6.1 

type ChannelListItem struct {
	Name      string
	UserCount int
	Topic     string
}

type ChannelStore 

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

func NewChannelStore 

func NewChannelStore() *ChannelStore

func (*ChannelStore) AddUser 

func (c *ChannelStore) AddUser(user, server, channel string)

func (*ChannelStore) GetTopic 

func (c *ChannelStore) GetTopic(server, channel string) string

func (*ChannelStore) GetUsers 

func (c *ChannelStore) GetUsers(server, channel string) []string

func (*ChannelStore) RemoveUser 

func (c *ChannelStore) RemoveUser(user, server, channel string)

func (*ChannelStore) RemoveUserAll 

func (c *ChannelStore) RemoveUserAll(user, server string)

func (*ChannelStore) RenameUser 

func (c *ChannelStore) RenameUser(oldNick, newNick, server string)

func (*ChannelStore) SetMode 

func (c *ChannelStore) SetMode(server, channel, user, add, remove string)

func (*ChannelStore) SetTopic 

func (c *ChannelStore) SetTopic(topic, server, channel string)

func (*ChannelStore) SetUsers 

func (c *ChannelStore) SetUsers(users []string, server, channel string)

type ChannelStoreUser 

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

func NewChannelStoreUser 

func NewChannelStoreUser(nick string) *ChannelStoreUser

func (*ChannelStoreUser) String 

func (c *ChannelStoreUser) String() string

type ClientSettings 

type ClientSettings struct {
	ColoredNicks bool
}

func DefaultClientSettings 

func DefaultClientSettings() *ClientSettings

func (*ClientSettings) Marshal 

func (d *ClientSettings) Marshal(buf []byte) ([]byte, error)

func (ClientSettings) MarshalEasyJSON 

func (v ClientSettings) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (ClientSettings) MarshalJSON 

func (v ClientSettings) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*ClientSettings) Size 

func (d *ClientSettings) Size() (s uint64)

func (*ClientSettings) Unmarshal 

func (d *ClientSettings) Unmarshal(buf []byte) (uint64, error)

func (*ClientSettings) UnmarshalEasyJSON 

func (v *ClientSettings) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*ClientSettings) UnmarshalJSON 

func (v *ClientSettings) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type MapChannelListIndex added in v0.6.1 

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

func NewMapChannelListIndex added in v0.6.1 

func NewMapChannelListIndex() *MapChannelListIndex

func (*MapChannelListIndex) Add added in v0.6.1 

func (idx *MapChannelListIndex) Add(item *ChannelListItem)

func (*MapChannelListIndex) Finish added in v0.6.1 

func (idx *MapChannelListIndex) Finish()

func (*MapChannelListIndex) Search added in v0.6.1 

func (idx *MapChannelListIndex) Search(q string) []*ChannelListItem

func (*MapChannelListIndex) SearchN added in v0.6.1 

func (idx *MapChannelListIndex) SearchN(q string, start, n int) []*ChannelListItem

type Message 

type Message struct {
	ID      string `json:"-" bleve:"-"`
	Server  string `json:"-" bleve:"server"`
	From    string `bleve:"-"`
	To      string `json:"-" bleve:"to"`
	Content string `bleve:"content"`
	Time    int64  `bleve:"-"`
}

func (*Message) Marshal 

func (d *Message) Marshal(buf []byte) ([]byte, error)

func (*Message) Size 

func (d *Message) Size() (s uint64)

func (Message) Type 

func (m Message) Type() string

func (*Message) Unmarshal 

func (d *Message) Unmarshal(buf []byte) (uint64, error)

type MessageSearchProvider 

type MessageSearchProvider interface {
	SearchMessages(server, channel, q string) ([]string, error)
	Index(id string, message *Message) error
	Close()
}

type MessageStore 

type MessageStore interface {
	LogMessage(message *Message) error
	GetMessages(server, channel string, count int, fromID string) ([]Message, bool, error)
	GetMessagesByID(server, channel string, ids []string) ([]Message, error)
	Close()
}

type Server 

type Server struct {
	Name     string
	Host     string
	Port     string
	TLS      bool
	Password string
	Nick     string
	Username string
	Realname string
}

func (*Server) Marshal 

func (d *Server) Marshal(buf []byte) ([]byte, error)

func (*Server) Size 

func (d *Server) Size() (s uint64)

func (*Server) Unmarshal 

func (d *Server) Unmarshal(buf []byte) (uint64, error)

type SessionStore 

type SessionStore interface {
	GetSessions() ([]*session.Session, error)
	SaveSession(session *session.Session) error
	DeleteSession(key string) error
}

type Store 

type Store interface {
	GetUsers() ([]*User, error)
	SaveUser(user *User) error
	DeleteUser(user *User) error

	GetServer(user *User, host string) (*Server, error)
	GetServers(user *User) ([]*Server, error)
	SaveServer(user *User, server *Server) error
	RemoveServer(user *User, host string) error

	GetChannels(user *User) ([]*Channel, error)
	AddChannel(user *User, channel *Channel) error
	RemoveChannel(user *User, server, channel string) error
}

type User 

type User struct {
	ID       uint64
	IDBytes  []byte
	Username string
	// contains filtered or unexported fields
}

func LoadUsers 

func LoadUsers(store Store) ([]*User, error)

func NewUser 

func NewUser(store Store) (*User, error)

func (*User) AddChannel 

func (u *User) AddChannel(channel *Channel) error

func (*User) AddServer 

func (u *User) AddServer(server *Server) error

func (*User) GetCertificate 

func (u *User) GetCertificate() *tls.Certificate

func (*User) GetChannels 

func (u *User) GetChannels() ([]*Channel, error)

func (*User) GetClientSettings 

func (u *User) GetClientSettings() *ClientSettings

func (*User) GetLastIP 

func (u *User) GetLastIP() []byte

func (*User) GetLastMessages 

func (u *User) GetLastMessages(server, channel string, count int) ([]Message, bool, error)

func (*User) GetMessages 

func (u *User) GetMessages(server, channel string, count int, fromID string) ([]Message, bool, error)

func (*User) GetServer added in v0.6.1 

func (u *User) GetServer(address string) (*Server, error)

func (*User) GetServers 

func (u *User) GetServers() ([]*Server, error)

func (*User) LogMessage 

func (u *User) LogMessage(id, server, from, to, content string) error

func (*User) Marshal 

func (d *User) Marshal(buf []byte) ([]byte, error)

func (*User) Remove 

func (u *User) Remove()

func (*User) RemoveChannel 

func (u *User) RemoveChannel(server, channel string) error

func (*User) RemoveServer 

func (u *User) RemoveServer(address string) error

func (*User) SearchMessages 

func (u *User) SearchMessages(server, channel, q string) ([]Message, error)

func (*User) SetCertificate 

func (u *User) SetCertificate(certPEM, keyPEM []byte) error

func (*User) SetClientSettings 

func (u *User) SetClientSettings(settings *ClientSettings) error

func (*User) SetLastIP 

func (u *User) SetLastIP(ip []byte) error

func (*User) SetMessageSearchProvider 

func (u *User) SetMessageSearchProvider(search MessageSearchProvider)

func (*User) SetMessageStore 

func (u *User) SetMessageStore(store MessageStore)

func (*User) SetNick 

func (u *User) SetNick(nick, address string) error

func (*User) SetServerName 

func (u *User) SetServerName(name, address string) error

func (*User) Size 

func (d *User) Size() (s uint64)

func (*User) Unmarshal 

func (d *User) Unmarshal(buf []byte) (uint64, error)

func (*User) UnmarshalClientSettingsJSON 

func (u *User) UnmarshalClientSettingsJSON(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.