deliverypebble

Documentation

Index

• func New(db *pebble.DB) *delivery.Repository
• func Register() container.Handler
• type Channel
  • func NewChannel(db *pebble.DB) *Channel
  • func (c Channel) Create(ctx context.Context, channel *delivery.Channel) error
  • func (c Channel) GetByID(ctx context.Context, id uuid.UUID) (*delivery.Channel, error)
  • func (c Channel) Update(ctx context.Context, input *delivery.ChannelUpdateInput) error
• type Message
  • func NewMessage(db *pebble.DB) *Message
  • func (m Message) Create(ctx context.Context, message *delivery.Message) error
  • func (m Message) Get(ctx context.Context, ch uuid.UUID, option *pletyvo.QueryOption) ([]*delivery.Message, error)
  • func (m Message) GetByID(ctx context.Context, ch, id uuid.UUID) (*delivery.Message, error)
  • func (m Message) Update(ctx context.Context, input *delivery.MessageUpdateInput) error

Functions

func New

func New(db *pebble.DB) *delivery.Repository

func Register

func Register() container.Handler

Types

type Channel

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

func NewChannel

func NewChannel(db *pebble.DB) *Channel

func (Channel) Create

func (c Channel) Create(ctx context.Context, channel *delivery.Channel) error

func (Channel) GetByID

func (c Channel) GetByID(ctx context.Context, id uuid.UUID) (*delivery.Channel, error)

func (Channel) Update

func (c Channel) Update(ctx context.Context, input *delivery.ChannelUpdateInput) error

type Message

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

func NewMessage

func NewMessage(db *pebble.DB) *Message

func (Message) Create

func (m Message) Create(ctx context.Context, message *delivery.Message) error

func (Message) Get

func (m Message) Get(ctx context.Context, ch uuid.UUID, option *pletyvo.QueryOption) ([]*delivery.Message, error)

func (Message) GetByID

func (m Message) GetByID(ctx context.Context, ch, id uuid.UUID) (*delivery.Message, error)

func (Message) Update

func (m Message) Update(ctx context.Context, input *delivery.MessageUpdateInput) error