memdb

Documentation

Index

• type Data
  • func NewData(size int64) *Data
  • func (d *Data) DataFS() fs.FS
  • func (d *Data) DeleteData(ctx context.Context, att *envelope.Attachment) error
  • func (d *Data) ForceCreateData(ctx context.Context, att *envelope.Attachment, data []byte) error
  • func (d *Data) GetData(ctx context.Context, att *envelope.Attachment) ([]byte, error)
  • func (d *Data) GetDataSize(ctx context.Context) (int64, error)
  • func (d *Data) Open(name string) (fs.File, error)
• type Endpoint
  • func NewEndpoint() *Endpoint
  • func (e *Endpoint) CreateEndpoint(end endpoint.Endpoint) error
  • func (e *Endpoint) GetEndpoint(name string) (endpoint.Endpoint, error)
  • func (e *Endpoint) ListEndpoint() []endpoint.Endpoint
• type Envelope
  • func NewEnvelope(limit int64) *Envelope
  • func (e *Envelope) CountAttachment(ctx context.Context) (int, error)
  • func (e *Envelope) CountEnvelope(ctx context.Context) (int, error)
  • func (e *Envelope) CreateEnvelope(ctx context.Context, msg *envelope.Message, atts []envelope.Attachment) (int64, error)
  • func (e *Envelope) DeleteEnvelope(ctx context.Context, msgID int64, fn func(env *envelope.Envelope) error) error
  • func (e *Envelope) GetEnvelope(ctx context.Context, msgID int64) (*envelope.Envelope, error)
  • func (e *Envelope) ListAttachment(ctx context.Context, offset, limit int, ascending bool) ([]envelope.Attachment, int, error)
  • func (e *Envelope) ListEnvelope(ctx context.Context, offset, limit int, ascending bool) ([]envelope.Envelope, int, error)

Types

type Data

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

func NewData

func NewData(size int64) *Data

func (*Data) DataFS

func (d *Data) DataFS() fs.FS

func (*Data) DeleteData

func (d *Data) DeleteData(ctx context.Context, att *envelope.Attachment) error

func (*Data) ForceCreateData

func (d *Data) ForceCreateData(ctx context.Context, att *envelope.Attachment, data []byte) error

func (*Data) GetData

func (d *Data) GetData(ctx context.Context, att *envelope.Attachment) ([]byte, error)

func (*Data) GetDataSize

func (d *Data) GetDataSize(ctx context.Context) (int64, error)

func (*Data) Open

func (d *Data) Open(name string) (fs.File, error)

type Endpoint

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

func NewEndpoint

func NewEndpoint() *Endpoint

func (*Endpoint) CreateEndpoint

func (e *Endpoint) CreateEndpoint(end endpoint.Endpoint) error

func (*Endpoint) GetEndpoint

func (e *Endpoint) GetEndpoint(name string) (endpoint.Endpoint, error)

func (*Endpoint) ListEndpoint

func (e *Endpoint) ListEndpoint() []endpoint.Endpoint

type Envelope

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

func NewEnvelope

func NewEnvelope(limit int64) *Envelope

func (*Envelope) CountAttachment

func (e *Envelope) CountAttachment(ctx context.Context) (int, error)

func (*Envelope) CountEnvelope

func (e *Envelope) CountEnvelope(ctx context.Context) (int, error)

func (*Envelope) CreateEnvelope

func (e *Envelope) CreateEnvelope(ctx context.Context, msg *envelope.Message, atts []envelope.Attachment) (int64, error)

func (*Envelope) DeleteEnvelope

func (e *Envelope) DeleteEnvelope(ctx context.Context, msgID int64, fn func(env *envelope.Envelope) error) error

func (*Envelope) GetEnvelope

func (e *Envelope) GetEnvelope(ctx context.Context, msgID int64) (*envelope.Envelope, error)

func (*Envelope) ListAttachment

func (e *Envelope) ListAttachment(ctx context.Context, offset, limit int, ascending bool) ([]envelope.Attachment, int, error)

func (*Envelope) ListEnvelope

func (e *Envelope) ListEnvelope(ctx context.Context, offset, limit int, ascending bool) ([]envelope.Envelope, int, error)