Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

core

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 DataLinkName

+ const FileLinkName

+ var ErrAccountRequired = errors.New("account required")

+ var ErrBlockExists = errors.New("block exists")

+ var ErrBlockNotFound = errors.New("block not found")

+ var ErrBlockWrongType = errors.New("block type is not the type requested")

+ var ErrContactNotFound = errors.New("contact not found")

+ var ErrFileNotFound = errors.New("file not found")

+ var ErrInvalidFileNode = errors.New("invalid files node")

+ var ErrInvalidThreadBlock = errors.New("invalid thread block")

+ var ErrJsonSchemaRequired = errors.New("thread schema does not allow json files")

+ var ErrMissingDataLink = errors.New("data link not in node")

+ var ErrMissingFileLink = errors.New("file link not in node")

+ var ErrNotAnnotatable = errors.New("thread is not annotatable")

+ var ErrNotReadable = errors.New("thread is not readable")

+ var ErrNotShareable = errors.New("thread is not shareable")

+ var ErrNotWritable = errors.New("thread is not writable")

+ var ErrOffline = errors.New("node is offline")

+ var ErrStarted = errors.New("node is started")

+ var ErrStopped = errors.New("node is stopped")

+ var ErrThreadInviteNotFound = errors.New("thread invite not found")

+ var ErrThreadLoaded = errors.New("thread is loaded")

+ var ErrThreadNotFound = errors.New("thread not found")

+ var ErrThreadSchemaRequired = errors.New("thread schema required to add files")

+ func FeedItemType(item *pb.FeedItem) (pb.Block_BlockType, error)

+ func GetRandomPort() string

+ func InitRepo(conf InitConfig) error

+ func MigrateRepo(conf MigrateConfig) error

+ type AddFileConfig struct

+ Input []byte

+ Media string

+ Name string

+ Plaintext bool

+ Use string

+ type BlockOutbox struct

+ func NewBlockOutbox(service func() *ThreadsService, node func() *core.IpfsNode, ...) *BlockOutbox

+ func (q *BlockOutbox) Add(pid peer.ID, env *pb.Envelope) error

+ func (q *BlockOutbox) Flush()

+ type CafeInbox struct

+ func NewCafeInbox(service func() *CafeService, threadsService func() *ThreadsService, ...) *CafeInbox

+ func (q *CafeInbox) Add(msg *pb.CafeMessage) error

+ func (q *CafeInbox) CheckMessages() error

+ func (q *CafeInbox) Flush()

+ type CafeOutbox struct

+ func NewCafeOutbox(service func() *CafeService, node func() *core.IpfsNode, ...) *CafeOutbox

+ func (q *CafeOutbox) Add(target string, rtype pb.CafeRequest_Type) error

+ func (q *CafeOutbox) Flush()

+ func (q *CafeOutbox) InboxRequest(pid peer.ID, env *pb.Envelope, inboxes []*pb.Cafe) error

+ type CafeService struct

+ func NewCafeService(account *keypair.Full, node func() *core.IpfsNode, datastore repo.Datastore, ...) *CafeService

+ func (h *CafeService) CheckMessages(cafe peer.ID) error

+ func (h *CafeService) DeleteMessages(cafe peer.ID) error

+ func (h *CafeService) DeliverMessage(mid string, pid peer.ID, cafe *pb.Cafe) error

+ func (h *CafeService) Deregister(cafe peer.ID) error

+ func (h *CafeService) Handle(pid peer.ID, env *pb.Envelope) (*pb.Envelope, error)

+ func (h *CafeService) HandleStream(pid peer.ID, env *pb.Envelope) (chan *pb.Envelope, chan error, chan interface{})

+ func (h *CafeService) Ping(pid peer.ID) (service.PeerStatus, error)

+ func (h *CafeService) Protocol() protocol.ID

+ func (h *CafeService) PublishPeer(peer *pb.Peer, cafe peer.ID) error

+ func (h *CafeService) Register(host string, token string) (*pb.CafeSession, error)

+ func (h *CafeService) Search(query *pb.Query, cafe peer.ID, reply func(*pb.QueryResult), ...) error

+ func (h *CafeService) Start()

+ func (h *CafeService) Store(cids []string, cafe peer.ID) ([]string, error)

+ func (h *CafeService) StoreThread(thrd *pb.Thread, cafe peer.ID) error

+ func (h *CafeService) Unstore(cids []string, cafe peer.ID) ([]string, error)

+ func (h *CafeService) UnstoreThread(id string, cafe peer.ID) error

+ type FeedItemPayload interface

+ GetDate func() *timestamp.Timestamp

+ GetUser func() *pb.User

+ ProtoMessage func()

+ Reset func()

+ String func() string

+ func GetFeedItemPayload(item *pb.FeedItem) (FeedItemPayload, error)

+ type InitConfig struct

+ Account *keypair.Full

+ ApiAddr string

+ CafeApiAddr string

+ CafeNeighborURL string

+ CafeOpen bool

+ CafePublicIP string

+ CafeURL string

+ Debug bool

+ GatewayAddr string

+ IsMobile bool

+ IsServer bool

+ LogToDisk bool

+ PinCode string

+ RepoPath string

+ SwarmPorts string

+ type MigrateConfig struct

+ PinCode string

+ RepoPath string

+ type PinResponse struct

+ Error string

+ Id string

+ type RunConfig struct

+ Debug bool

+ PinCode string

+ RepoPath string

+ type SubsystemInfo map[string]string

+ type Textile struct

+ func NewTextile(conf RunConfig) (*Textile, error)

+ func (t *Textile) AcceptExternalInvite(inviteId string, key []byte) (mh.Multihash, error)

+ func (t *Textile) AcceptInvite(inviteId string) (mh.Multihash, error)

+ func (t *Textile) AcceptInviteViaNotification(id string) (mh.Multihash, error)

+ func (t *Textile) Account() *keypair.Full

+ func (t *Textile) AccountContact() *pb.Contact

+ func (t *Textile) AccountThread() *Thread

+ func (t *Textile) AddContact(card *pb.Contact) error

+ func (t *Textile) AddExternalInvite(threadId string) (*pb.ExternalInvite, error)

+ func (t *Textile) AddFileIndex(mill m.Mill, conf AddFileConfig) (*pb.FileIndex, error)

+ func (t *Textile) AddInvite(threadId string, address string) error

+ func (t *Textile) AddNodeFromDirs(dirs *pb.DirectoryList) (ipld.Node, *pb.Keys, error)

+ func (t *Textile) AddNodeFromFiles(files []*pb.FileIndex) (ipld.Node, *pb.Keys, error)

+ func (t *Textile) AddOrUpdateThread(thrd *pb.Thread) error

+ func (t *Textile) AddSchema(jsonstr string, name string) (*pb.FileIndex, error)

+ func (t *Textile) AddThread(conf pb.AddThreadConfig, sk libp2pc.PrivKey, initiator string, join bool, ...) (*Thread, error)

+ func (t *Textile) ApiAddr() string

+ func (t *Textile) Avatar() string

+ func (t *Textile) Block(id string) (*pb.Block, error)

+ func (t *Textile) BlockView(id string) (*pb.Block, error)

+ func (t *Textile) Blocks(offset string, limit int, query string) *pb.BlockList

+ func (t *Textile) BlocksByTarget(target string) *pb.BlockList

+ func (t *Textile) CafeApiAddr() string

+ func (t *Textile) CafeInfo() *pb.Cafe

+ func (t *Textile) CafeSession(peerId string) (*pb.CafeSession, error)

+ func (t *Textile) CafeSessions() *pb.CafeSessionList

+ func (t *Textile) CafeTokens() ([]string, error)

+ func (t *Textile) CheckCafeMessages() error

+ func (t *Textile) CloseChns()

+ func (t *Textile) Comment(blockId string) (*pb.Comment, error)

+ func (t *Textile) Comments(target string) (*pb.CommentList, error)

+ func (t *Textile) Config() *config.Config

+ func (t *Textile) Contact(address string) *pb.Contact

+ func (t *Textile) ContactThreads(address string) (*pb.ThreadList, error)

+ func (t *Textile) Contacts() *pb.ContactList

+ func (t *Textile) CountUnreadNotifications() int

+ func (t *Textile) CreateCafeToken(token string, store bool) (string, error)

+ func (t *Textile) DataAtPath(path string) ([]byte, error)

+ func (t *Textile) Decrypt(input []byte) ([]byte, error)

+ func (t *Textile) DeregisterCafe(peerId string) error

+ func (t *Textile) DoneCh() <-chan struct{}

+ func (t *Textile) Encrypt(input []byte) ([]byte, error)

+ func (t *Textile) Feed(req *pb.FeedRequest) (*pb.FeedItemList, error)

+ func (t *Textile) File(blockId string) (*pb.Files, error)

+ func (t *Textile) FileData(hash string) (io.ReadSeeker, *pb.FileIndex, error)

+ func (t *Textile) FileIndex(hash string) (*pb.FileIndex, error)

+ func (t *Textile) Files(offset string, limit int, threadId string) (*pb.FilesList, error)

+ func (t *Textile) GetMedia(reader io.Reader, mill m.Mill) (string, error)

+ func (t *Textile) IgnoreInvite(inviteId string) error

+ func (t *Textile) IgnoreInviteViaNotification(id string) error

+ func (t *Textile) InviteView(invite *pb.Invite) *pb.InviteView

+ func (t *Textile) Invites() *pb.InviteViewList

+ func (t *Textile) Ipfs() *core.IpfsNode

+ func (t *Textile) Like(blockId string) (*pb.Like, error)

+ func (t *Textile) Likes(target string) (*pb.LikeList, error)

+ func (t *Textile) LinksAtPath(path string) ([]*ipld.Link, error)

+ func (t *Textile) Message(blockId string) (*pb.Text, error)

+ func (t *Textile) Messages(offset string, limit int, threadId string) (*pb.TextList, error)

+ func (t *Textile) Mobile() bool

+ func (t *Textile) Name() string

+ func (t *Textile) NotificationCh() <-chan *pb.Notification

+ func (t *Textile) NotificationView(note *pb.Notification) *pb.Notification

+ func (t *Textile) Notifications(offset string, limit int) *pb.NotificationList

+ func (t *Textile) Online() bool

+ func (t *Textile) OnlineCh() <-chan struct{}

+ func (t *Textile) PeerId() (peer.ID, error)

+ func (t *Textile) PeerUser(id string) *pb.User

+ func (t *Textile) Ping(pid peer.ID) (service.PeerStatus, error)

+ func (t *Textile) Profile() *pb.Peer

+ func (t *Textile) ReadAllNotifications() error

+ func (t *Textile) ReadNotification(id string) error

+ func (t *Textile) RefreshCafeSession(peerId string) (*pb.CafeSession, error)

+ func (t *Textile) RegisterCafe(host string, token string) (*pb.CafeSession, error)

+ func (t *Textile) RemoveCafeToken(token string) error

+ func (t *Textile) RemoveContact(address string) error

+ func (t *Textile) RemoveThread(id string) (mh.Multihash, error)

+ func (t *Textile) RenameThread(id string, name string) error

+ func (t *Textile) RepoPath() string

+ func (t *Textile) SearchContacts(query *pb.ContactQuery, options *pb.QueryOptions) (<-chan *pb.QueryResult, <-chan error, *broadcast.Broadcaster, error)

+ func (t *Textile) SearchThreadSnapshots(query *pb.ThreadSnapshotQuery, options *pb.QueryOptions) (<-chan *pb.QueryResult, <-chan error, *broadcast.Broadcaster, error)

+ func (t *Textile) SetAvatar(hash string) error

+ func (t *Textile) SetLogLevel(level *pb.LogLevel) error

+ func (t *Textile) SetName(name string) error

+ func (t *Textile) Sign(input []byte) ([]byte, error)

+ func (t *Textile) SnapshotThreads() error

+ func (t *Textile) Start() error

+ func (t *Textile) StartApi(addr string, serveDocs bool)

+ func (t *Textile) Started() bool

+ func (t *Textile) Stop() error

+ func (t *Textile) StopApi() error

+ func (t *Textile) Summary() *pb.Summary

+ func (t *Textile) SyncAccount(options *pb.QueryOptions) (*broadcast.Broadcaster, error)

+ func (t *Textile) TargetNodeKeys(node ipld.Node) (*pb.Keys, error)

+ func (t *Textile) Thread(id string) *Thread

+ func (t *Textile) ThreadByKey(key string) *Thread

+ func (t *Textile) ThreadPeers(id string) (*pb.PeerList, error)

+ func (t *Textile) ThreadUpdateListener() *broadcast.Listener

+ func (t *Textile) ThreadView(id string) (*pb.Thread, error)

+ func (t *Textile) Threads() []*Thread

+ func (t *Textile) UpdateCh() <-chan *pb.WalletUpdate

+ func (t *Textile) ValidateCafeToken(token string) (bool, error)

+ func (t *Textile) Verify(input []byte, sig []byte) error

+ func (t *Textile) Writer() io.Writer

+ type Thread struct

+ Id string

+ Key string

+ Name string

+ Schema *pb.Node

+ func NewThread(model *pb.Thread, conf *ThreadConfig) (*Thread, error)

+ func (t *Thread) AddComment(target string, body string) (mh.Multihash, error)

+ func (t *Thread) AddExternalInvite() (mh.Multihash, []byte, error)

+ func (t *Thread) AddFiles(node ipld.Node, caption string, keys map[string]string) (mh.Multihash, error)

+ func (t *Thread) AddFlag(block string) (mh.Multihash, error)

+ func (t *Thread) AddIgnore(block string) (mh.Multihash, error)

+ func (t *Thread) AddInvite(p *pb.Peer) (mh.Multihash, error)

+ func (t *Thread) AddLike(target string) (mh.Multihash, error)

+ func (t *Thread) AddMessage(body string) (mh.Multihash, error)

+ func (t *Thread) Decrypt(data []byte) ([]byte, error)

+ func (t *Thread) Encrypt(data []byte) ([]byte, error)

+ func (t *Thread) Head() (string, error)

+ func (t *Thread) Peers() []pb.ThreadPeer

+ type ThreadConfig struct

+ Account *keypair.Full

+ AddPeer func(*pb.Peer) error

+ BlockOutbox *BlockOutbox

+ CafeOutbox *CafeOutbox

+ Config *config.Config

+ Datastore repo.Datastore

+ Node func() *core.IpfsNode

+ PushUpdate func(*pb.Block, string)

+ RepoPath string

+ Service func() *ThreadsService

+ type ThreadsService struct

+ func NewThreadsService(account *keypair.Full, node func() *core.IpfsNode, datastore repo.Datastore, ...) *ThreadsService

+ func (h *ThreadsService) Handle(pid peer.ID, env *pb.Envelope) (*pb.Envelope, error)

+ func (h *ThreadsService) HandleStream(pid peer.ID, env *pb.Envelope) (chan *pb.Envelope, chan error, chan interface{})

+ func (h *ThreadsService) NewEnvelope(threadId string, hash mh.Multihash, ciphertext []byte, sig []byte) (*pb.Envelope, error)

+ func (h *ThreadsService) Ping(pid peer.ID) (service.PeerStatus, error)

+ func (h *ThreadsService) Protocol() protocol.ID

+ func (h *ThreadsService) SendMessage(ctx context.Context, pid peer.ID, env *pb.Envelope) error

+ func (h *ThreadsService) Start()

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 Version

+ type NodeConfig struct

+ LogFiles bool

+ LogLevel logging.Level

+ WalletConfig w.Config

+ type TextileNode struct

+ Wallet *w.Wallet

+ var Node *TextileNode

+ func NewNode(config NodeConfig) (*TextileNode, string, error)

+ func (t *TextileNode) GetGatewayAddr() string

+ func (t *TextileNode) StartGateway(addr string)

+ func (t *TextileNode) StartWallet() error

+ func (t *TextileNode) StopGateway() error

+ func (t *TextileNode) StopWallet() error