natslogs

Documentation

Index

• type LogMessage
• type Repository
  • func New(conn *nats.Conn, repo domain.GoodsRepository, subject string) *Repository
  • func (r *Repository) CreateItem(ctx context.Context, projectId int, name string) (*repository.GoodsItem, error)
  • func (r *Repository) DeleteItem(ctx context.Context, id int, projectId int) (*repository.GoodsItem, error)
  • func (r *Repository) GetItem(ctx context.Context, id int, projectId int) (*repository.GoodsItem, error)
  • func (r *Repository) ListItems(ctx context.Context, limit int, offset int) ([]repository.GoodsItem, error)
  • func (r *Repository) Reprioritize(ctx context.Context, id int, projectId int, startPriority int) ([]repository.GoodsItem, error)
  • func (r *Repository) UpdateItem(ctx context.Context, id int, projectId int, name string, description string) (*repository.GoodsItem, error)

Types

type LogMessage

type LogMessage struct {
	Id          int       `json:"Id"`
	ProjectId   int       `json:"ProjectId"`
	Name        string    `json:"Name"`
	Description string    `json:"Description"`
	Priority    int       `json:"Priority"`
	Removed     bool      `json:"Removed"`
	EventTime   time.Time `json:"EventTime"`
}

type Repository

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

func New

func New(conn *nats.Conn, repo domain.GoodsRepository, subject string) *Repository

func (*Repository) CreateItem

func (r *Repository) CreateItem(ctx context.Context, projectId int, name string) (*repository.GoodsItem, error)

func (*Repository) DeleteItem

func (r *Repository) DeleteItem(ctx context.Context, id int, projectId int) (*repository.GoodsItem, error)

func (*Repository) GetItem

func (r *Repository) GetItem(ctx context.Context, id int, projectId int) (*repository.GoodsItem, error)

func (*Repository) ListItems

func (r *Repository) ListItems(ctx context.Context, limit int, offset int) ([]repository.GoodsItem, error)

func (*Repository) Reprioritize

func (r *Repository) Reprioritize(ctx context.Context, id int, projectId int, startPriority int) ([]repository.GoodsItem, error)

func (*Repository) UpdateItem

func (r *Repository) UpdateItem(ctx context.Context, id int, projectId int, name string, description string) (*repository.GoodsItem, error)