remote

Documentation

Index

• Variables
• type Manager
  • func New(dir string) *Manager
  • func (m *Manager) AddUser(userID, username, password string, conn connector.Connector) (*User, error)
  • func (m *Manager) GetUserID(username, password string) (string, error)
• type OpMailboxCreate
• type OpMailboxDelete
• type OpMailboxUpdate
• type OpMessageAdd
• type OpMessageCreate
• type OpMessageFlagged
• type OpMessageRemove
• type OpMessageSeen
• type User
  • func (user *User) AddMessagesToMailbox(ctx context.Context, messageIDs []string, mboxID string) error
  • func (user *User) Close() error
  • func (user *User) CreateMailbox(ctx context.Context, name []string) (imap.Mailbox, error)
  • func (user *User) CreateMessage(ctx context.Context, mboxID string, literal []byte, flags imap.FlagSet, ...) (imap.Message, error)
  • func (user *User) DeleteMailbox(ctx context.Context, mboxID string, name []string) error
  • func (user *User) GetUpdates() <-chan imap.Update
  • func (user *User) RemoveMessagesFromMailbox(ctx context.Context, messageIDs []string, mboxID string) error
  • func (user *User) SetMessagesFlagged(ctx context.Context, messageIDs []string, flagged bool) error
  • func (user *User) SetMessagesSeen(ctx context.Context, messageIDs []string, seen bool) error
  • func (user *User) UpdateMailbox(ctx context.Context, mboxID string, oldName, newName []string) error

Variables

var ErrNoSuchUser = errors.New("no such user")

var ErrQueueClosed = errors.New("the queue is closed")

Types

type Manager

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

Manager provides access to remote users.

func New

func New(dir string) *Manager

New returns a new manager which stores serialized operation queues for users in the given base directory.

func (*Manager) AddUser

func (m *Manager) AddUser(userID, username, password string, conn connector.Connector) (*User, error)

AddUser adds the remote user with the given (IMAP) credentials to the remote manager. The user interacts with the remote via the given connector.

func (*Manager) GetUserID

func (m *Manager) GetUserID(username, password string) (string, error)

GetUserID returns the user ID of the user with the given credentials.

type OpMailboxCreate

type OpMailboxCreate struct {
	TempID string
	Name   []string
}

type OpMailboxDelete

type OpMailboxDelete struct {
	MBoxID string
}

type OpMailboxUpdate

type OpMailboxUpdate struct {
	MBoxID string
	Name   []string
}

type OpMessageAdd

type OpMessageAdd struct {
	MessageIDs []string
	MBoxID     string
}

type OpMessageCreate

type OpMessageCreate struct {
	TempID  string
	MBoxID  string
	Literal []byte
	Flags   imap.FlagSet
	Date    time.Time
}

type OpMessageFlagged

type OpMessageFlagged struct {
	MessageIDs []string
	Flagged    bool
}

type OpMessageRemove

type OpMessageRemove struct {
	MessageIDs []string
	MBoxID     string
}

type OpMessageSeen

type OpMessageSeen struct {
	MessageIDs []string
	Seen       bool
}

type User

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

User performs operations against a remote server using a connector.

func (*User) AddMessagesToMailbox

func (user *User) AddMessagesToMailbox(ctx context.Context, messageIDs []string, mboxID string) error

AddMessageToMailbox adds the message with the given ID to the mailbox with the given ID.

func (*User) Close

func (user *User) Close() error

Close closes the remote user.

func (*User) CreateMailbox

func (user *User) CreateMailbox(ctx context.Context, name []string) (imap.Mailbox, error)

CreateMailbox creates a new mailbox with the given name.

func (*User) CreateMessage

func (user *User) CreateMessage(ctx context.Context, mboxID string, literal []byte, flags imap.FlagSet, date time.Time) (imap.Message, error)

CreateMessage appends a message literal to the mailbox with the given ID.

func (*User) DeleteMailbox

func (user *User) DeleteMailbox(ctx context.Context, mboxID string, name []string) error

DeleteMailbox deletes the mailbox with the given ID and name.

func (*User) GetUpdates

func (user *User) GetUpdates() <-chan imap.Update

GetUpdates returns a channel on which updates from the server are sent.

func (*User) RemoveMessagesFromMailbox

func (user *User) RemoveMessagesFromMailbox(ctx context.Context, messageIDs []string, mboxID string) error

RemoveMessageFromMailbox removes the message with the given ID from the mailbox with the given ID.

func (*User) SetMessagesFlagged

func (user *User) SetMessagesFlagged(ctx context.Context, messageIDs []string, flagged bool) error

SetMessageFlagged marks the message with the given ID as seen or unseen.

func (*User) SetMessagesSeen

func (user *User) SetMessagesSeen(ctx context.Context, messageIDs []string, seen bool) error

SetMessageSeen marks the message with the given ID as seen or unseen.

func (*User) UpdateMailbox

func (user *User) UpdateMailbox(ctx context.Context, mboxID string, oldName, newName []string) error

UpdateMailbox sets the name of the mailbox with the given ID to the given new name.