Versions in this module Expand all Collapse all v1 v1.13.0 Dec 24, 2023 v1.11.1 Dec 26, 2023 Changes in this version + var File_queue_proto protoreflect.FileDescriptor + var Recipient_Status_name = map[int32]string + var Recipient_Status_value = map[string]int32 + var Recipient_Type_name = map[int32]string + var Recipient_Type_value = map[string]int32 + type Item struct + CreatedAt time.Time + func ItemFromFile(fname string) (*Item, error) + func (item *Item) SendLoop(q *Queue) + func (item *Item) WriteTo(dir string) error + type Message struct + CreatedAtTs *Timestamp + Data []byte + From string + ID string + Rcpt []*Recipient + To []string + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (x *Message) GetCreatedAtTs() *Timestamp + func (x *Message) GetData() []byte + func (x *Message) GetFrom() string + func (x *Message) GetID() string + func (x *Message) GetRcpt() []*Recipient + func (x *Message) GetTo() []string + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type Queue struct + func New(path string, localDomains *set.String, aliases *aliases.Resolver, ...) (*Queue, error) + func (q *Queue) DumpString() string + func (q *Queue) Len() int + func (q *Queue) Load() error + func (q *Queue) Put(tr *trace.Trace, from string, to []string, data []byte) (string, error) + func (q *Queue) Remove(id string) + type Recipient struct + Address string + LastFailureMessage string + OriginalAddress string + Status Recipient_Status + Type Recipient_Type + func (*Recipient) Descriptor() ([]byte, []int) + func (*Recipient) ProtoMessage() + func (x *Recipient) GetAddress() string + func (x *Recipient) GetLastFailureMessage() string + func (x *Recipient) GetOriginalAddress() string + func (x *Recipient) GetStatus() Recipient_Status + func (x *Recipient) GetType() Recipient_Type + func (x *Recipient) ProtoReflect() protoreflect.Message + func (x *Recipient) Reset() + func (x *Recipient) String() string + type Recipient_Status int32 + const Recipient_FAILED + const Recipient_PENDING + const Recipient_SENT + func (Recipient_Status) Descriptor() protoreflect.EnumDescriptor + func (Recipient_Status) EnumDescriptor() ([]byte, []int) + func (Recipient_Status) Type() protoreflect.EnumType + func (x Recipient_Status) Enum() *Recipient_Status + func (x Recipient_Status) Number() protoreflect.EnumNumber + func (x Recipient_Status) String() string + type Recipient_Type int32 + const Recipient_EMAIL + const Recipient_PIPE + func (Recipient_Type) Descriptor() protoreflect.EnumDescriptor + func (Recipient_Type) EnumDescriptor() ([]byte, []int) + func (Recipient_Type) Type() protoreflect.EnumType + func (x Recipient_Type) Enum() *Recipient_Type + func (x Recipient_Type) Number() protoreflect.EnumNumber + func (x Recipient_Type) String() string + type Timestamp struct + Nanos int32 + Seconds int64 + func (*Timestamp) Descriptor() ([]byte, []int) + func (*Timestamp) ProtoMessage() + func (x *Timestamp) GetNanos() int32 + func (x *Timestamp) GetSeconds() int64 + func (x *Timestamp) ProtoReflect() protoreflect.Message + func (x *Timestamp) Reset() + func (x *Timestamp) String() string