Documentation
¶
Overview ¶
Example (Flags) ¶
package main import ( "context" "flag" "fmt" "berty.tech/berty/v2/go/internal/initutil" "moul.io/u" ) 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 {"RemoteAddr":"","Listeners":""} 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 ¶
- Constants
- type Manager
- func (m *Manager) Close() error
- func (m *Manager) DisableIPFSNetwork()
- func (m *Manager) GetContext() context.Context
- func (m *Manager) GetDatastoreDir() (string, error)
- func (m *Manager) GetGRPCClientConn() (*grpc.ClientConn, error)
- func (m *Manager) GetGRPCServer() (*grpc.Server, *runtime.ServeMux, error)
- func (m *Manager) GetLocalIPFS() (ipfsutil.ExtendedCoreAPI, *ipfs_core.IpfsNode, error)
- func (m *Manager) GetLocalMessengerServer() (bertymessenger.MessengerServiceServer, error)
- func (m *Manager) GetLocalProtocolServer() (bertyprotocol.Service, error)
- func (m *Manager) GetLogger() (*zap.Logger, error)
- func (m *Manager) GetMessengerClient() (bertymessenger.MessengerServiceClient, error)
- func (m *Manager) GetMessengerDB() (*gorm.DB, error)
- func (m *Manager) GetOrbitDB() (*bertyprotocol.BertyOrbitDB, error)
- func (m *Manager) GetProtocolClient() (bertyprotocol.ProtocolServiceClient, error)
- func (m *Manager) GetRootDatastore() (datastore.Batching, error)
- func (m *Manager) RunWorkers() error
- func (m *Manager) SetupDatastoreFlags(fs *flag.FlagSet)
- func (m *Manager) SetupDefaultGRPCListenersFlags(fs *flag.FlagSet)
- func (m *Manager) SetupEmptyGRPCListenersFlags(fs *flag.FlagSet)
- func (m *Manager) SetupLocalIPFSFlags(fs *flag.FlagSet)
- func (m *Manager) SetupLocalMessengerServerFlags(fs *flag.FlagSet)
- func (m *Manager) SetupLocalProtocolServerFlags(fs *flag.FlagSet)
- func (m *Manager) SetupLoggingFlags(fs *flag.FlagSet)
- func (m *Manager) SetupRemoteNodeFlags(fs *flag.FlagSet)
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 Logfile string Filters string Tracer string // contains filtered or unexported fields } Datastore struct { Dir string InMemory bool // contains filtered or unexported fields } Node struct { Protocol struct { IPFSListeners string LocalDiscovery bool RdvpMaddr string MinBackoff time.Duration MaxBackoff time.Duration DisableIPFSNetwork bool // contains filtered or unexported fields } Messenger struct { DisplayName string DisableNotifications bool RebuildSqlite bool MessengerSqliteOpts string // contains filtered or unexported fields } GRPC struct { RemoteAddr string Listeners string // contains filtered or unexported fields } // contains filtered or unexported fields } // contains filtered or unexported fields }
func (*Manager) DisableIPFSNetwork ¶
func (m *Manager) DisableIPFSNetwork()
func (*Manager) GetContext ¶
func (*Manager) GetDatastoreDir ¶
func (*Manager) GetGRPCClientConn ¶
func (m *Manager) GetGRPCClientConn() (*grpc.ClientConn, error)
func (*Manager) GetGRPCServer ¶
func (*Manager) GetLocalIPFS ¶ added in v2.141.0
func (*Manager) GetLocalMessengerServer ¶
func (m *Manager) GetLocalMessengerServer() (bertymessenger.MessengerServiceServer, error)
func (*Manager) GetLocalProtocolServer ¶
func (m *Manager) GetLocalProtocolServer() (bertyprotocol.Service, error)
func (*Manager) GetMessengerClient ¶
func (m *Manager) GetMessengerClient() (bertymessenger.MessengerServiceClient, 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) RunWorkers ¶
func (*Manager) SetupDatastoreFlags ¶
func (*Manager) SetupDefaultGRPCListenersFlags ¶ added in v2.141.1
func (*Manager) SetupEmptyGRPCListenersFlags ¶ added in v2.141.1
func (*Manager) SetupLocalIPFSFlags ¶ added in v2.141.0
func (*Manager) SetupLocalMessengerServerFlags ¶
func (*Manager) SetupLocalProtocolServerFlags ¶
func (*Manager) SetupLoggingFlags ¶
func (*Manager) SetupRemoteNodeFlags ¶
Click to show internal directories.
Click to hide internal directories.