classifications

Documentation

Index

• Constants
• type DistributedRepo
  • func NewDistributeRepo(remoteClient cluster.Client, memberLister cluster.MemberLister, ...) *DistributedRepo
  • func (r *DistributedRepo) Get(ctx context.Context, id strfmt.UUID) (*models.Classification, error)
  • func (r *DistributedRepo) Put(ctx context.Context, pl models.Classification) error
  • func (r *DistributedRepo) TxManager() *cluster.TxManager
• type Repo
  • func NewRepo(baseDir string, logger logrus.FieldLogger) (*Repo, error)
  • func (r *Repo) DBPath() string
  • func (r *Repo) Get(ctx context.Context, id strfmt.UUID) (*models.Classification, error)
  • func (r *Repo) Put(ctx context.Context, classification models.Classification) error

Constants

const DefaultTxTTL = 60 * time.Second

Types

type DistributedRepo

type DistributedRepo struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDistributeRepo

func NewDistributeRepo(remoteClient cluster.Client,
	memberLister cluster.MemberLister, localRepo localRepo,
	logger logrus.FieldLogger,
) *DistributedRepo

func (*DistributedRepo) Get

func (r *DistributedRepo) Get(ctx context.Context,
	id strfmt.UUID,
) (*models.Classification, error)

func (*DistributedRepo) Put

func (r *DistributedRepo) Put(ctx context.Context,
	pl models.Classification,
) error

func (*DistributedRepo) TxManager

func (r *DistributedRepo) TxManager() *cluster.TxManager

type Repo

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

func NewRepo

func NewRepo(baseDir string, logger logrus.FieldLogger) (*Repo, error)

func (*Repo) DBPath

func (r *Repo) DBPath() string

func (*Repo) Get

func (r *Repo) Get(ctx context.Context, id strfmt.UUID) (*models.Classification, error)

func (*Repo) Put

func (r *Repo) Put(ctx context.Context, classification models.Classification) error