core

Documentation

Index

• Variables
• type Config
• 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) (*Textile, error)
  • func (t *Textile) Bootstrap()
  • func (t *Textile) Close(force bool) 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 {
	RepoPath string

	AddrAPI      ma.Multiaddr
	AddrAPIProxy ma.Multiaddr

	AddrMongoURI  string
	AddrMongoName string

	AddrThreadsHost  ma.Multiaddr
	AddrIPFSAPI      ma.Multiaddr
	AddrBillingAPI   string
	AddrPowergateAPI string

	AddrGatewayHost ma.Multiaddr
	AddrGatewayURL  string

	ThreadsConnManager connmgr.ConnManager

	UseSubdomains bool

	DNSDomain string
	DNSZoneID string
	DNSToken  string

	EmailFrom          string
	EmailDomain        string
	EmailAPIKey        string
	EmailSessionSecret string

	MaxBucketSize            int64
	MaxNumberThreadsPerOwner int

	Hub   bool
	Debug bool

	PowergateAdminToken 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) (*Textile, error)

func (*Textile) Bootstrap

func (t *Textile) Bootstrap()

func (*Textile) Close

func (t *Textile) Close(force bool) error

func (*Textile) HostID

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