bertymessenger

type Dispatcher struct {
	// contains filtered or unexported fields
}

type MetaFetcherFromProtocolClient struct {
	// contains filtered or unexported fields
}

type Notifiee interface {
	StreamEvent(*messengertypes.StreamEvent) error
}

type NotifieeBundle struct {
	StreamEventImpl func(c *messengertypes.StreamEvent) error
}

type Opts struct {
	EnableGroupMonitor  bool
	Logger              *zap.Logger
	DB                  *gorm.DB
	NotificationManager notification.Manager
	LifeCycleManager    *lifecycle.Manager
	StateBackup         *mt.LocalDatabaseState
	PushKey             *[cryptoutil.KeySize]byte
	PlatformPushToken   *pushtypes.PushServiceReceiver
	Ring                *zapring.Core
	GRPCInsecureMode    bool

	// LogFilePath defines the location of the current session's log file.
	//
	// This variable is used by svc.TyberHostAttach.
	LogFilePath string
}

type RecvEvent struct {
	// contains filtered or unexported fields
}

type Service interface {
	mt.MessengerServiceServer
	Close()
}

type ServiceClient interface {
	messengertypes.MessengerServiceClient

	io.Closer
}

type TestingAccount struct {
	// contains filtered or unexported fields
}

type TestingService struct {
	Logger  *zap.Logger
	Service Service
	Client  ServiceClient
}

type TestingServiceOpts struct {
	Logger      *zap.Logger
	Client      weshnet.ServiceClient
	DB          *gorm.DB
	Index       int
	Ring        *zapring.Core
	LogFilePath string
	PushSK      *[32]byte
}