initutil

Documentation

Index

• Constants
• type Manager
  • func New(ctx context.Context) (*Manager, error)
  • func (m *Manager) CancelContext()
  • 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) 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) 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) 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)

Constants

const InMemoryDir = ":memory:"

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 {
			IPFSListeningPort  uint
			LocalDiscovery     bool
			RdvpMaddr          string
			GRPCListeners      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
			// contains filtered or unexported fields
		}
	}
	// contains filtered or unexported fields
}

func New

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

func (*Manager) CancelContext

func (m *Manager) CancelContext()

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) GetGRPCServer

func (m *Manager) GetGRPCServer() (*grpc.Server, *runtime.ServeMux, 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) 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) SetupDatastoreFlags

func (m *Manager) SetupDatastoreFlags(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) SetupRemoteNodeFlags

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