core

Documentation

Index

• Variables
• type Config
• type Option
  • func WithBadgerThreadsPersistence(repoPath string) Option
  • func WithMongoThreadsPersistence(uri, db string) Option
• type Options
• type StatsHandler
  • func (h *StatsHandler) HandleConn(context.Context, stats.ConnStats)
  • func (h *StatsHandler) HandleRPC(ctx context.Context, st stats.RPCStats)
  • func (h *StatsHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context
  • func (h *StatsHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context
• type Textile
  • func NewTextile(ctx context.Context, conf Config, opts ...Option) (*Textile, error)
  • func (t *Textile) Bootstrap()
  • func (t *Textile) Close() error
  • func (t *Textile) HostID() peer.ID

Variables

var (
	// ErrTooManyThreadsPerOwner indicates that the maximum amount of threads
	// are created for an owner.
	ErrTooManyThreadsPerOwner = errors.New("number of threads per owner exceeds quota")
)

Types

type Config

type Config struct {
	Hub   bool
	Debug bool

	// Addresses
	AddrAPI          ma.Multiaddr
	AddrAPIProxy     ma.Multiaddr
	AddrMongoURI     string
	AddrMongoName    string
	AddrThreadsHost  ma.Multiaddr
	AddrGatewayHost  ma.Multiaddr
	AddrGatewayURL   string
	AddrIPFSAPI      ma.Multiaddr
	AddrBillingAPI   string
	AddrPowergateAPI string

	// Buckets
	MaxBucketArchiveRepFactor int
	MaxBucketArchiveSize      int64
	MinBucketArchiveSize      int64

	// Threads
	MaxNumberThreadsPerOwner int
	ThreadsConnManager       connmgr.ConnManager

	// IPNS
	IPNSRepublishSchedule    string
	IPNSRepublishConcurrency int

	// Powergate
	PowergateAdminToken string

	// Archives
	ArchiveJobPollIntervalSlow time.Duration
	ArchiveJobPollIntervalFast time.Duration

	// Gateway
	UseSubdomains   bool
	MaxEventsPerSec int
	MaxBurstSize    int

	// Cloudflare
	DNSDomain string
	DNSZoneID string
	DNSToken  string

	// Customer.io
	CustomerioAPIKey      string
	CustomerioConfirmTmpl string
	CustomerioInviteTmpl  string
	EmailSessionSecret    string
}

type Option

type Option func(*Options)

func WithBadgerThreadsPersistence

func WithBadgerThreadsPersistence(repoPath string) Option

func WithMongoThreadsPersistence

func WithMongoThreadsPersistence(uri, db string) Option

type Options

type Options struct {
	ThreadsBadgerRepoPath string
	ThreadsMongoUri       string
	ThreadsMongoDB        string
}

type StatsHandler

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

func (*StatsHandler) HandleConn

func (h *StatsHandler) HandleConn(context.Context, stats.ConnStats)

func (*StatsHandler) HandleRPC

func (h *StatsHandler) HandleRPC(ctx context.Context, st stats.RPCStats)

HandleRPC accounts for customer usage across services.

func (*StatsHandler) TagConn

func (h *StatsHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context

func (*StatsHandler) TagRPC

func (h *StatsHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context

type Textile

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

func NewTextile

func NewTextile(ctx context.Context, conf Config, opts ...Option) (*Textile, error)

func (*Textile) Bootstrap

func (t *Textile) Bootstrap()

func (*Textile) Close

func (t *Textile) Close() error

func (*Textile) HostID

func (t *Textile) HostID() peer.ID