textile

Documentation

Index

• Variables
• func NewClient(store db.Store) *textileClient
• func NotFound(slug string) error
• type Buckd
• type Bucket
• type BucketData
• type BucketRoot
• type BucketsClient
• type Client
• type DirEntries
• type EventHandler
• type TextileBuckd
  • func NewBuckd(cfg config.Config) *TextileBuckd
  • func (tb *TextileBuckd) Shutdown() error
  • func (tb *TextileBuckd) Start(ctx context.Context) error
  • func (tb *TextileBuckd) Stop() error
• type TextileThreadsd
  • func (tt *TextileThreadsd) Start() error
  • func (tt *TextileThreadsd) Stop() error
  • func (tt *TextileThreadsd) WaitForReady() chan bool
• type ThreadListener
  • func NewListener(textileClient Client, bucketSlug string, handlers []EventHandler) ThreadListener
• type Threadsd
  • func NewThreadsd() Threadsd

Variables

var IpfsAddr string

var MongoHost string

var MongoPw string

var MongoUsr string

Functions

func NewClient

func NewClient(store db.Store) *textileClient

Creates a new Textile Client

func NotFound

func NotFound(slug string) error

Types

type Buckd

type Buckd interface {
	Stop() error
	Start(ctx context.Context) error
}

type Bucket

type Bucket interface {
	Slug() string
	Key() string
	GetData() BucketData
	GetContext(ctx context.Context) (context.Context, *thread.ID, error)
	DirExists(ctx context.Context, path string) (bool, error)
	FileExists(ctx context.Context, path string) (bool, error)
	UploadFile(
		ctx context.Context,
		path string,
		reader io.Reader,
	) (result path.Resolved, root path.Path, err error)
	GetFile(
		ctx context.Context,
		path string,
		w io.Writer,
	) error
	CreateDirectory(
		ctx context.Context,
		path string,
	) (result path.Resolved, root path.Path, err error)
	ListDirectory(
		ctx context.Context,
		path string,
	) (*DirEntries, error)
	DeleteDirOrFile(
		ctx context.Context,
		path string,
	) (path.Resolved, error)
}

type BucketData

type BucketData struct {
	Key       string `json:"_id"`
	Name      string `json:"name"`
	Path      string `json:"path"`
	DNSRecord string `json:"dns_record,omitempty"`
	//Archives  Archives `json:"archives"`
	CreatedAt int64 `json:"created_at"`
	UpdatedAt int64 `json:"updated_at"`
}

type BucketRoot

type BucketRoot buckets_pb.Root

type BucketsClient

type BucketsClient interface {
	PushPath(ctx context.Context, key, pth string, reader io.Reader, opts ...bucketsClient.Option) (result path.Resolved, root path.Resolved, err error)
	PullPath(ctx context.Context, key, pth string, writer io.Writer, opts ...bucketsClient.Option) error
	ListPath(ctx context.Context, key, pth string) (*bucketsproto.ListPathReply, error)
	RemovePath(ctx context.Context, key, pth string, opts ...bucketsClient.Option) (path.Resolved, error)
}

type Client

type Client interface {
	IsRunning() bool
	GetDefaultBucket(ctx context.Context) (Bucket, error)
	GetBucket(ctx context.Context, slug string) (Bucket, error)
	GetBaseThreadsContext(ctx context.Context) (context.Context, error)
	GetBucketContext(ctx context.Context, bucketSlug string) (context.Context, *thread.ID, error)
	GetLocalBucketContext(ctx context.Context, bucketSlug string) (context.Context, *thread.ID, error)
	GetThreadsConnection() (*threadsClient.Client, error)
	ListBuckets(ctx context.Context) ([]Bucket, error)
	CreateBucket(ctx context.Context, bucketSlug string) (Bucket, error)
	Shutdown() error
	WaitForReady() chan bool
	StartAndBootstrap(ctx context.Context, cfg config.Config) error
}

type DirEntries

type DirEntries buckets_pb.ListPathReply

type EventHandler

type EventHandler interface {
	OnCreate(bucketData *BucketData, listenEvent *tc.ListenEvent)
	OnRemove(bucketData *BucketData, listenEvent *tc.ListenEvent)
	OnSave(bucketData *BucketData, listenEvent *tc.ListenEvent)
}

EventHandler

type TextileBuckd

type TextileBuckd struct {
	IsRunning bool
	// contains filtered or unexported fields
}

func NewBuckd

func NewBuckd(cfg config.Config) *TextileBuckd

func (*TextileBuckd) Shutdown

func (tb *TextileBuckd) Shutdown() error

func (*TextileBuckd) Start

func (tb *TextileBuckd) Start(ctx context.Context) error

func (*TextileBuckd) Stop

func (tb *TextileBuckd) Stop() error

type TextileThreadsd

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

func (*TextileThreadsd) Start

func (tt *TextileThreadsd) Start() error

func (*TextileThreadsd) Stop

func (tt *TextileThreadsd) Stop() error

func (*TextileThreadsd) WaitForReady

func (tt *TextileThreadsd) WaitForReady() chan bool

type ThreadListener

type ThreadListener interface {
	Listen(ctx context.Context) error
	Close()
	RegisterHandler(handler EventHandler)
}

func NewListener

func NewListener(textileClient Client, bucketSlug string, handlers []EventHandler) ThreadListener

type Threadsd

type Threadsd interface {
	WaitForReady() chan bool
	Stop() error
	Start() error
}

func NewThreadsd

func NewThreadsd() Threadsd