userevents

type AddressEventHandler interface {
	HandleAddressEvents(ctx context.Context, events []proton.AddressEvent) error
}

type ChanneledSubscriber[T any] struct {
	// contains filtered or unexported fields
}

type ChanneledSubscriberEvent[T any] struct {
	// contains filtered or unexported fields
}

type EventChanneledSubscriber = ChanneledSubscriber[proton.Event]

type EventController interface {
	Pause()
	Resume()
}

type EventHandler struct {
	RefreshHandler      RefreshEventHandler
	AddressHandler      AddressEventHandler
	UserHandler         UserEventHandler
	LabelHandler        LabelEventHandler
	MessageHandler      MessageEventHandler
	UsedSpaceHandler    UserUsedSpaceEventHandler
	UserSettingsHandler UserSettingsHandler
}

type EventIDStore interface {
	// Load the last stored event, return "" for empty.
	Load(ctx context.Context) (string, error)
	// Store the new id.
	Store(ctx context.Context, id string) error
}

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

type EventSource interface {
	GetLatestEventID(ctx context.Context) (string, error)
	GetEvent(ctx context.Context, id string) ([]proton.Event, bool, error)
}

type EventSubscriber = subscriber[proton.Event]

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

type LabelEventHandler interface {
	HandleLabelEvents(ctx context.Context, events []proton.LabelEvent) error
}

type MessageEventHandler interface {
	HandleMessageEvents(ctx context.Context, events []proton.MessageEvent) error
}

type NoOpSubscribable struct{}

type NullEventSource struct{}

type RefreshEventHandler interface {
	HandleRefreshEvent(ctx context.Context, flag proton.RefreshFlag) error
}

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

type Subscribable interface {
	Subscribe(subscription EventSubscriber)
	Unsubscribe(subscription EventSubscriber)
}

type Subscription = EventSubscriber

type UserEventHandler interface {
	HandleUserEvent(ctx context.Context, user *proton.User) error
}

type UserSettingsHandler interface {
	HandleUserSettingsEvent(ctx context.Context, settings *proton.UserSettings) error
}

type UserUsedSpaceEventHandler interface {
	HandleUsedSpaceEvent(ctx context.Context, newSpace int64) error
}

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