repo

package

Go to main page

Versions in this module

v0

v0.1.11

Mar 29, 2019

v0.1.10

Mar 29, 2019

Changes in this version

+ const Repover

+ var ErrMigrationRequired = errors.New("repo needs migration")

+ var ErrRepoCorrupted = errors.New("repo is corrupted")

+ var ErrRepoDoesNotExist = errors.New("repo does not exist, initialization is required")

+ func Init(repoPath string) error

+ func LoadPlugins(repoPath string) (*loader.PluginLoader, error)

+ func MigrateUp(repoPath string, pinCode string, testnet bool) error

+ func Stat(repoPath string) error

+ type BlockMessageStore interface

+ Add func(msg *pb.BlockMessage) error

+ Delete func(id string) error

+ List func(offset string, limit int) []pb.BlockMessage

type BlockStore

+ DeleteByThread func(threadId string) error

+ type CafeClientMessageStore interface

+ AddOrUpdate func(message *pb.CafeClientMessage) error

+ CountByClient func(clientId string) int

+ Delete func(id string, clientId string) error

+ DeleteByClient func(clientId string, limit int) error

+ ListByClient func(clientId string, limit int) []pb.CafeClientMessage

+ type CafeClientNonceStore interface

+ Add func(nonce *pb.CafeClientNonce) error

+ Delete func(value string) error

+ Get func(value string) *pb.CafeClientNonce

+ type CafeClientStore interface

+ Add func(account *pb.CafeClient) error

+ Count func() int

+ Delete func(id string) error

+ Get func(id string) *pb.CafeClient

+ List func() []pb.CafeClient

+ ListByAddress func(address string) []pb.CafeClient

+ UpdateLastSeen func(id string, date time.Time) error

+ type CafeClientThreadStore interface

+ AddOrUpdate func(thrd *pb.CafeClientThread) error

+ Delete func(id string, clientId string) error

+ DeleteByClient func(clientId string) error

+ ListByClient func(clientId string) []pb.CafeClientThread

+ type CafeMessageStore interface

+ Add func(msg *pb.CafeMessage) error

+ AddAttempt func(id string) error

+ Delete func(id string) error

+ List func(offset string, limit int) []pb.CafeMessage

+ type CafeRequestStore interface

+ Add func(req *pb.CafeRequest) error

+ Delete func(id string) error

+ DeleteByCafe func(cafeId string) error

+ List func(offset string, limit int) []pb.CafeRequest

+ type CafeSessionStore interface

+ AddOrUpdate func(session *pb.CafeSession) error

+ Delete func(cafeId string) error

+ Get func(cafeId string) *pb.CafeSession

+ List func() *pb.CafeSessionList

+ type CafeTokenStore interface

+ Add func(token *pb.CafeToken) error

+ Delete func(id string) error

+ Get func(id string) *pb.CafeToken

+ List func() []pb.CafeToken

type ConfigStore

+ GetAccount func() (*keypair.Full, error)

+ GetLastDaily func() (time.Time, error)

+ SetLastDaily func() error

type Datastore

+ BlockMessages func() BlockMessageStore

+ CafeClientMessages func() CafeClientMessageStore

+ CafeClientNonces func() CafeClientNonceStore

+ CafeClientThreads func() CafeClientThreadStore

+ CafeClients func() CafeClientStore

+ CafeMessages func() CafeMessageStore

+ CafeRequests func() CafeRequestStore

+ CafeSessions func() CafeSessionStore

+ CafeTokens func() CafeTokenStore

+ Files func() FileStore

+ Invites func() InviteStore

+ ThreadPeers func() ThreadPeerStore

+ type FileStore interface

+ Add func(file *pb.FileIndex) error

+ AddTarget func(hash string, target string) error

+ Count func() int

+ Delete func(hash string) error

+ Get func(hash string) *pb.FileIndex

+ GetByPrimary func(mill string, checksum string) *pb.FileIndex

+ GetBySource func(mill string, source string, opts string) *pb.FileIndex

+ RemoveTarget func(hash string, target string) error

+ type InviteStore interface

+ Add func(invite *pb.Invite) error

+ Delete func(id string) error

+ Get func(id string) *pb.Invite

+ List func() *pb.InviteList

type Migration

+ Major func() bool

type NotificationStore

+ DeleteByActor func(actorId string) error

+ DeleteByBlock func(blockId string) error

+ DeleteBySubject func(subjectId string) error

type PeerStore

+ AddOrUpdate func(peer *pb.Peer) error

+ DeleteByAddress func(address string) error

+ Find func(address string, username string, exclude []string) []*pb.Peer

+ GetBest func(id string) *pb.Peer

+ UpdateAvatar func(id string, avatar string) error

+ UpdateInboxes func(id string, inboxes []*pb.Cafe) error

+ UpdateName func(id string, name string) error

+ type ThreadPeerStore interface

+ Add func(peer *pb.ThreadPeer) error

+ Count func(distinct bool) int

+ Delete func(id string, thread string) error

+ DeleteById func(id string) error

+ DeleteByThread func(thread string) error

+ List func() []pb.ThreadPeer

+ ListById func(id string) []pb.ThreadPeer

+ ListByThread func(threadId string) []pb.ThreadPeer

+ ListUnwelcomedByThread func(threadId string) []pb.ThreadPeer

+ WelcomeByThread func(thread string) error

type ThreadStore

+ GetByKey func(key string) *pb.Thread

+ UpdateName func(id string, name string) error

v0.1.10-rc4

Mar 26, 2019

v0.1.10-rc3

Mar 19, 2019

v0.1.10-rc2

Mar 18, 2019

v0.1.10-rc1

Mar 16, 2019

v0.1.9

Sep 11, 2018

Changes in this version

+ const MAGIC

+ var ErrRepoExists = errors.New("repo not empty, reinitializing would overwrite your keys")

+ func CreatePointerKey(mh multihash.Multihash, prefixLen int) multihash.Multihash

+ func DoInit(repoRoot string, version string, mnemonic *string, initDB func(string) error, ...) (string, error)

+ func FindPointers(dht *routing.IpfsDHT, ctx context.Context, mhKey multihash.Multihash, ...) ([]ps.PeerInfo, error)

+ func FindPointersAsync(dht *routing.IpfsDHT, ctx context.Context, mhKey multihash.Multihash, ...) <-chan ps.PeerInfo

+ func GetPointersFromPeer(node *core.IpfsNode, ctx context.Context, p peer.ID, key *cid.Cid) ([]*ps.PeerInfo, error)

+ func PublishPointer(node *core.IpfsNode, ctx context.Context, pointer Pointer) error

+ func PutPointerToPeer(node *core.IpfsNode, ctx context.Context, peer peer.ID, pointer Pointer) error

+ type Block struct

+ AuthorPk string

+ AuthorUsernameCipher []byte

+ DataCaptionCipher []byte

+ DataId string

+ DataKeyCipher []byte

+ DataMetadataCipher []byte

+ Date time.Time

+ Id string

+ Parents []string

+ ThreadId string

+ Type BlockType

+ type BlockStore interface

+ Add func(block *Block) error

+ Count func(query string) int

+ Delete func(id string) error

+ DeleteByThreadId func(threadId string) error

+ Get func(id string) *Block

+ GetByDataId func(dataId string) *Block

+ List func(offset string, limit int, query string) []Block

+ type BlockType int

+ const CommentBlock

+ const ExternalInviteBlock

+ const IgnoreBlock

+ const InviteBlock

+ const JoinBlock

+ const LeaveBlock

+ const LikeBlock

+ const MergeBlock

+ const PhotoBlock

+ func (b BlockType) Description() string

+ type CafeTokens struct

+ Access string

+ Expiry time.Time

+ Refresh string

+ type ConfigStore interface

+ Configure func(created time.Time) error

+ GetCreationDate func() (time.Time, error)

+ Init func(password string) error

+ IsEncrypted func() bool

+ type DataBlockConfig struct

+ DataCaptionCipher []byte

+ DataId string

+ DataKeyCipher []byte

+ DataMetadataCipher []byte

+ type Datastore interface

+ Blocks func() BlockStore

+ Close func()

+ Config func() ConfigStore

+ Devices func() DeviceStore

+ Notifications func() NotificationStore

+ OfflineMessages func() OfflineMessageStore

+ Peers func() PeerStore

+ PinRequests func() PinRequestStore

+ Ping func() error

+ Pointers func() PointerStore

+ Profile func() ProfileStore

+ Threads func() ThreadStore

+ type Device struct

+ Id string

+ Name string

+ type DeviceStore interface

+ Add func(device *Device) error

+ Count func(query string) int

+ Delete func(id string) error

+ Get func(id string) *Device

+ List func(query string) []Device

+ type Migration interface

+ Down func(repoPath string, dbPassword string, testnet bool) error

+ Up func(repoPath string, dbPassword string, testnet bool) error

+ type Notification struct

+ ActorId string

+ ActorUsername string

+ BlockId string

+ Body string

+ DataId string

+ Date time.Time

+ Id string

+ Read bool

+ Subject string

+ SubjectId string

+ Type NotificationType

+ type NotificationStore interface

+ Add func(notification *Notification) error

+ CountUnread func() int

+ Delete func(id string) error

+ DeleteByActorId func(actorId string) error

+ DeleteByBlockId func(blockId string) error

+ DeleteBySubjectId func(subjectId string) error

+ Get func(id string) *Notification

+ List func(offset string, limit int, query string) []Notification

+ Read func(id string) error

+ ReadAll func() error

+ type NotificationType int

+ const CommentAddedNotification

+ const DeviceAddedNotification

+ const LikeAddedNotification

+ const PeerJoinedNotification

+ const PeerLeftNotification

+ const PhotoAddedNotification

+ const ReceivedInviteNotification

+ const TextAddedNotification

+ func (n NotificationType) Description() string

+ type OfflineMessageStore interface

+ DeleteMessage func(url string) error

+ GetMessages func() (map[string][]byte, error)

+ Has func(url string) bool

+ Put func(url string) error

+ SetMessage func(url string, message []byte) error

+ type Peer struct

+ Id string

+ PubKey []byte

+ Row string

+ ThreadId string

+ type PeerStore interface

+ Add func(peer *Peer) error

+ Count func(query string, distinct bool) int

+ Delete func(id string, thread string) error

+ DeleteByThreadId func(thread string) error

+ Get func(row string) *Peer

+ GetById func(id string) *Peer

+ List func(offset string, limit int, query string) []Peer

+ type PinRequest struct

+ Date time.Time

+ Id string

+ type PinRequestStore interface

+ Delete func(id string) error

+ List func(offset string, limit int) []PinRequest

+ Put func(pr *PinRequest) error

+ type Pointer struct

+ CancelId *peer.ID

+ Cid *cid.Cid

+ Date time.Time

+ Purpose Purpose

+ Value ps.PeerInfo

+ func NewPointer(mhKey multihash.Multihash, prefixLen int, addr ma.Multiaddr, entropy []byte) (Pointer, error)

+ type PointerStore interface

+ Delete func(id peer.ID) error

+ DeleteAll func(purpose Purpose) error

+ Get func(id peer.ID) *Pointer

+ GetAll func() ([]Pointer, error)

+ GetByPurpose func(purpose Purpose) ([]Pointer, error)

+ Put func(p Pointer) error

+ type ProfileStore interface

+ GetAvatarId func() (*string, error)

+ GetTokens func() (tokens *CafeTokens, err error)

+ GetUsername func() (*string, error)

+ SetAvatarId func(id string) error

+ SignIn func(username string, tokens *CafeTokens) error

+ SignOut func() error

+ UpdateTokens func(tokens *CafeTokens) error

+ type Purpose int

+ const CHANNEL

+ const MESSAGE

+ const MODERATOR

+ const TAG

+ type Queryable interface

+ BeginTransaction func() (*sql.Tx, error)

+ ExecuteQuery func(string, ...interface{}) (sql.Result, error)

+ PrepareAndExecuteQuery func(string, ...interface{}) (*sql.Rows, error)

+ PrepareQuery func(string) (*sql.Stmt, error)

+ type Thread struct

+ Head string

+ Id string

+ Name string

+ PrivKey []byte

+ type ThreadStore interface

+ Add func(thread *Thread) error

+ Count func(query string) int

+ Delete func(id string) error

+ Get func(id string) *Thread

+ List func(query string) []Thread

+ UpdateHead func(id string, head string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL