config

Jan 10, 2024

Changes in this version

type DirectAnnounce

+ NoPubsubAnnounce bool

Sep 1, 2023

Changes in this version

type PublisherKind

+ const Libp2pHttpPublisherKind

+ const Libp2pPublisherKind

Apr 11, 2023

Changes in this version

type DelegatedRouting

+ AdFlushFrequency Duration

Apr 4, 2023

Changes in this version

type Config

+ DelegatedRouting DelegatedRouting

+ type DelegatedRouting struct

+ Addrs []string

+ ChunkSize int

+ CidTtl Duration

+ DsPageSize int

+ ListenMultiaddr string

+ ProviderID string

+ ReadTimeout Duration

+ SnapshotSize int

+ WriteTimeout Duration

+ func NewDelegatedRouting() DelegatedRouting

+ func (as *DelegatedRouting) ListenNetAddr() (string, error)

+ func (c *DelegatedRouting) PopulateDefaults()

Jan 9, 2023

Changes in this version

+ const DefaultConfigFile

+ const DefaultPathName

+ const DefaultPathRoot

+ const EnvDir

+ const PrivateKeyPathEnvVar

+ var ErrInitialized = errors.New("configuration file already exists")

+ var ErrInvalidPeerAddr = errors.New("invalid peer address")

+ var ErrNotInitialized = errors.New("not initialized")

+ func Filename(configRoot string) (string, error)

+ func Marshal(value interface{}) ([]byte, error)

+ func Path(configRoot, configFile string) (string, error)

+ func PathRoot() (string, error)

+ type AdminServer struct

+ ListenMultiaddr string

+ ReadTimeout Duration

+ WriteTimeout Duration

+ func NewAdminServer() AdminServer

+ func (as *AdminServer) ListenNetAddr() (string, error)

+ func (c *AdminServer) PopulateDefaults()

+ type Bootstrap struct

+ MinimumPeers int

+ Peers []string

+ func NewBootstrap() Bootstrap

+ func (b *Bootstrap) SetPeers(addrs []peer.AddrInfo)

+ func (b Bootstrap) PeerAddrs() ([]peer.AddrInfo, error)

+ type Config struct

+ AdminServer AdminServer

+ Bootstrap Bootstrap

+ Datastore Datastore

+ DirectAnnounce DirectAnnounce

+ Identity Identity

+ Ingest Ingest

+ ProviderServer ProviderServer

+ Reframe Reframe

+ func Init(out io.Writer) (*Config, error)

+ func InitWithIdentity(identity Identity) (*Config, error)

+ func Load(filePath string) (*Config, error)

+ func (c *Config) PopulateDefaults()

+ func (c *Config) Save(filePath string) error

+ func (c *Config) String() string

+ type Datastore struct

+ Dir string

+ Type string

+ func NewDatastore() Datastore

+ func (c *Datastore) PopulateDefaults()

+ type DirectAnnounce struct

+ URLs []string

+ func NewDirectAnnounce() DirectAnnounce

+ func (d DirectAnnounce) ParseURLs() ([]*url.URL, error)

+ type Duration time.Duration

+ func (d *Duration) UnmarshalText(text []byte) error

+ func (d Duration) MarshalText() ([]byte, error)

+ func (d Duration) String() string

+ type HttpPublisher struct

+ AnnounceMultiaddr string

+ ListenMultiaddr string

+ func NewHttpPublisher() HttpPublisher

+ func (hs *HttpPublisher) ListenNetAddr() (string, error)

+ type Identity struct

+ PeerID string

+ PrivKey string

+ func CreateIdentity(out io.Writer) (Identity, error)

+ func (identity Identity) DecodeOrCreate(out io.Writer) (peer.ID, ic.PrivKey, error)

+ func (identity Identity) DecodeOrCreatePrivateKey(out io.Writer, passphrase string) (ic.PrivKey, error)

+ type Ingest struct

+ HttpPublisher HttpPublisher

+ LinkCacheSize int

+ LinkedChunkSize int

+ PubSubTopic string

+ PublisherKind PublisherKind

+ PurgeLinkCache bool

+ SyncPolicy Policy

+ func NewIngest() Ingest

+ func (c *Ingest) PopulateDefaults()

+ type Policy struct

+ Allow bool

+ Except []string

+ func NewPolicy() Policy

+ type ProviderServer struct

+ ListenMultiaddr string

+ RetrievalMultiaddrs []string

+ func NewProviderServer() ProviderServer

+ func (c *ProviderServer) PopulateDefaults()

+ type PublisherKind string

+ const DTSyncPublisherKind

+ const HttpPublisherKind

+ type Reframe struct

+ Addrs []string

+ ChunkSize int

+ CidTtl Duration

+ DsPageSize int

+ ListenMultiaddr string

+ ProviderID string

+ ReadTimeout Duration

+ SnapshotSize int

+ WriteTimeout Duration

+ func NewReframe() Reframe

+ func (as *Reframe) ListenNetAddr() (string, error)

+ func (c *Reframe) PopulateDefaults()