initutil

package
v2.192.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 27, 2020 License: Apache-2.0, MIT Imports: 67 Imported by: 0

Documentation

Overview

Example (Flags) 
package main

import (
	"context"
	"flag"
	"fmt"

	"moul.io/u"

	"berty.tech/berty/v2/go/internal/initutil"
)

func main() {
	// init manager
	ctx := context.Background()
	manager, err := initutil.New(ctx)
	if err != nil {
		panic(err)
	}
	defer manager.Close()

	// configure flags
	fmt.Println("before", u.JSON(manager.Node.GRPC))
	fs := flag.NewFlagSet("test", flag.ExitOnError)
	manager.SetupLocalProtocolServerFlags(fs)
	manager.SetupRemoteNodeFlags(fs)
	manager.SetupDefaultGRPCListenersFlags(fs)
	err = fs.Parse([]string{"-store.inmem", "-p2p.min-backoff=2m10s", "-node.remote-addr=1.2.3.4:5678"})
	if err != nil {
		panic(err)
	}
	fmt.Println("after ", u.JSON(manager.Node.GRPC))

}

Output:

before {}
after  {"RemoteAddr":"1.2.3.4:5678","Listeners":"/ip4/127.0.0.1/tcp/9091/grpc"}
Example (Noflags) 
package main

import (
	"context"
	"flag"
	"fmt"

	"berty.tech/berty/v2/go/internal/initutil"
	"berty.tech/berty/v2/go/pkg/bertytypes"
)

func main() {
	// init manager
	ctx := context.Background()
	manager, err := initutil.New(ctx)
	if err != nil {
		panic(err)
	}
	defer manager.Close()

	fs := flag.NewFlagSet("", flag.ExitOnError)
	manager.SetupLocalProtocolServerFlags(fs)
	manager.SetupRemoteNodeFlags(fs)
	fs.Parse([]string{})

	// configure manager without flags
	manager.Node.GRPC.Listeners = ""
	manager.Node.Protocol.DisableIPFSNetwork = true
	manager.Datastore.InMemory = true

	// start a local berty protocol server
	_, err = manager.GetLocalProtocolServer()
	if err != nil {
		panic(err)
	}

	// build a client for the previously created protocol server
	client, err := manager.GetProtocolClient()
	if err != nil {
		panic(err)
	}

	// retrieve config
	ret, err := client.InstanceGetConfiguration(ctx, &bertytypes.InstanceGetConfiguration_Request{})
	if err != nil {
		panic(err)
	}

	// check that the reply is valid (cannot check hardcoded value, since it's random)
	fmt.Println(ret.AccountPK != nil)

}

Output:

true

Index

Examples

Constants

View Source 
const InMemoryDir = ":memory:"

Variables

This section is empty.

Functions

This section is empty.

Types

type Manager 

type Manager struct {
	Logging struct {
		Format  string `json:"Format,omitempty"`
		Logfile string `json:"Logfile,omitempty"`
		Filters string `json:"Filters,omitempty"`
		Tracer  string `json:"Tracer,omitempty"`
		Service string `json:"Service,omitempty"`
		// contains filtered or unexported fields
	} `json:"Logging,omitempty"`
	Metrics struct {
		Listener string `json:"Listener,omitempty"`
		Pedantic bool   `json:"Pedantic,omitempty"`
		// contains filtered or unexported fields
	} `json:"Metrics,omitempty"`
	Datastore struct {
		Dir      string `json:"Dir,omitempty"`
		InMemory bool   `json:"InMemory,omitempty"`
		FileIO   bool   `json:"FileIO,omitempty"`
		// contains filtered or unexported fields
	} `json:"Datastore,omitempty"`
	Node struct {
		Preset   Preset
		Protocol struct {
			IPFSListeners         flagStringSlice `json:"IPFSListeners,omitempty"`
			IPFSAPIListeners      flagStringSlice `json:"IPFSAPIListeners,omitempty"`
			IPFSWebUIListener     string          `json:"IPFSWebUIListener,omitempty"`
			Announce              flagStringSlice `json:"Announce,omitempty"`
			NoAnnounce            flagStringSlice `json:"NoAnnounce,omitempty"`
			LocalDiscovery        bool            `json:"LocalDiscovery,omitempty"`
			MultipeerConnectivity bool            `json:"MultipeerConnectivity,omitempty"`
			MinBackoff            time.Duration   `json:"MinBackoff,omitempty"`
			MaxBackoff            time.Duration   `json:"MaxBackoff,omitempty"`
			DisableIPFSNetwork    bool            `json:"DisableIPFSNetwork,omitempty"`
			RdvpMaddrs            flagStringSlice `json:"RdvpMaddrs,omitempty"`
			AuthSecret            string          `json:"AuthSecret,omitempty"`
			AuthPublicKey         string          `json:"AuthPublicKey,omitempty"`
			Tor                   struct {
				Enabled    bool   `json:"Enabled,omitempty"`
				BinaryPath string `json:"BinaryPath,omitempty"`
			} `json:"Tor,omitempty"`
			// contains filtered or unexported fields
		}
		Messenger struct {
			DisplayName          string `json:"DisplayName,omitempty"`
			DisableNotifications bool   `json:"DisableNotifications,omitempty"`
			RebuildSqlite        bool   `json:"RebuildSqlite,omitempty"`
			MessengerSqliteOpts  string `json:"MessengerSqliteOpts,omitempty"`
			ExportPathToRestore  string `json:"ExportPathToRestore,omitempty"`
			// contains filtered or unexported fields
		}
		GRPC struct {
			RemoteAddr string `json:"RemoteAddr,omitempty"`
			Listeners  string `json:"Listeners,omitempty"`
			// contains filtered or unexported fields
		} `json:"GRPC,omitempty"`
	} `json:"Node,omitempty"`
	// contains filtered or unexported fields
}

func New 

func New(ctx context.Context) (*Manager, error)

func (*Manager) Close 

func (m *Manager) Close() error

func (*Manager) DisableIPFSNetwork 

func (m *Manager) DisableIPFSNetwork()

func (*Manager) GetContext 

func (m *Manager) GetContext() context.Context

func (*Manager) GetDatastoreDir 

func (m *Manager) GetDatastoreDir() (string, error)

func (*Manager) GetGRPCClientConn 

func (m *Manager) GetGRPCClientConn() (*grpc.ClientConn, error)

func (*Manager) GetGRPCListeners added in v2.190.1 

func (m *Manager) GetGRPCListeners() []grpcutil.Listener

func (*Manager) GetGRPCServer 

func (m *Manager) GetGRPCServer() (*grpc.Server, *grpcgw.ServeMux, error)

func (*Manager) GetLifecycleManager added in v2.145.0 

func (m *Manager) GetLifecycleManager() *lifecycle.Manager

func (*Manager) GetLocalIPFS added in v2.141.0 

func (m *Manager) GetLocalIPFS() (ipfsutil.ExtendedCoreAPI, *ipfs_core.IpfsNode, error)

func (*Manager) GetLocalMessengerServer 

func (m *Manager) GetLocalMessengerServer() (bertymessenger.MessengerServiceServer, error)

func (*Manager) GetLocalProtocolServer 

func (m *Manager) GetLocalProtocolServer() (bertyprotocol.Service, error)

func (*Manager) GetLogger 

func (m *Manager) GetLogger() (*zap.Logger, error)

func (*Manager) GetMessengerClient 

func (m *Manager) GetMessengerClient() (bertymessenger.MessengerServiceClient, error)

func (*Manager) GetMessengerDB 

func (m *Manager) GetMessengerDB() (*gorm.DB, error)

func (*Manager) GetMetricsRegistry added in v2.182.0 

func (m *Manager) GetMetricsRegistry() (*prometheus.Registry, error)

func (*Manager) GetNotificationManager added in v2.190.1 

func (m *Manager) GetNotificationManager() (notification.Manager, error)

func (*Manager) GetOrbitDB added in v2.141.0 

func (m *Manager) GetOrbitDB() (*bertyprotocol.BertyOrbitDB, error)

func (*Manager) GetProtocolClient 

func (m *Manager) GetProtocolClient() (bertyprotocol.ProtocolServiceClient, error)

func (*Manager) GetRootDatastore 

func (m *Manager) GetRootDatastore() (datastore.Batching, error)

func (*Manager) RunWorkers 

func (m *Manager) RunWorkers() error

func (*Manager) SetLifecycleManager added in v2.190.1 

func (m *Manager) SetLifecycleManager(manager *lifecycle.Manager)

func (*Manager) SetLogger added in v2.190.1 

func (m *Manager) SetLogger(logger *zap.Logger)

func (*Manager) SetNotificationManager added in v2.190.1 

func (m *Manager) SetNotificationManager(manager notification.Manager)

func (*Manager) SetupDatastoreFlags 

func (m *Manager) SetupDatastoreFlags(fs *flag.FlagSet)

func (*Manager) SetupDefaultGRPCListenersFlags added in v2.141.1 

func (m *Manager) SetupDefaultGRPCListenersFlags(fs *flag.FlagSet)

func (*Manager) SetupEmptyGRPCListenersFlags added in v2.141.1 

func (m *Manager) SetupEmptyGRPCListenersFlags(fs *flag.FlagSet)

func (*Manager) SetupLocalIPFSFlags added in v2.141.0 

func (m *Manager) SetupLocalIPFSFlags(fs *flag.FlagSet)

func (*Manager) SetupLocalMessengerServerFlags 

func (m *Manager) SetupLocalMessengerServerFlags(fs *flag.FlagSet)

func (*Manager) SetupLocalProtocolServerFlags 

func (m *Manager) SetupLocalProtocolServerFlags(fs *flag.FlagSet)

func (*Manager) SetupLoggingFlags 

func (m *Manager) SetupLoggingFlags(fs *flag.FlagSet)

func (*Manager) SetupMetricsFlags added in v2.182.0 

func (m *Manager) SetupMetricsFlags(fs *flag.FlagSet)

func (*Manager) SetupNotificationManagerFlags added in v2.190.1 

func (m *Manager) SetupNotificationManagerFlags(fs *flag.FlagSet)

func (*Manager) SetupProtocolAuth added in v2.154.0 

func (m *Manager) SetupProtocolAuth(fs *flag.FlagSet)

func (*Manager) SetupRemoteNodeFlags 

func (m *Manager) SetupRemoteNodeFlags(fs *flag.FlagSet)

type Preset added in v2.187.0 

type Preset int
const (
	PresetDefault Preset = iota
	PresetAnonymity
)

func (*Preset) Set added in v2.187.0 

func (p *Preset) Set(value string) error

func (Preset) String added in v2.187.0 

func (p Preset) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.