crudstore

package
v0.0.0-...-783eb67 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 6, 2022 License: BSD-2-Clause Imports: 15 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	RecordNotFound = errors.New("not found")
	RecordDeleted  = errors.New("deleted")
)
View Source
var (
	InvalidArgumentError = errors.New("invalid argument")
)

Functions

func EntityTypeFromStruct

func EntityTypeFromStruct(msg interface{}) string

func IsDuplicate

func IsDuplicate(err error) bool

func IsErrDeleted

func IsErrDeleted(err error) bool

func IsErrNotFound

func IsErrNotFound(err error) bool

func NewClient

func NewClient(ctx context.Context, dbUri string) (*clientProvider, error)

func NewClientWithStore

func NewClientWithStore(crudStore CrudStore) *clientProvider

Types

type Client

type Client interface {
	Create(msg interface{}) (*common.Originator, error)
	Get(originator *common.Originator, msg interface{}, deleted bool) error
	Update(msg interface{}) (*common.Originator, error)
	Delete(originator *common.Originator, msg interface{}) (*common.Originator, error)
	ListWithPagination(result interface{}, fromID string, size int) (string, error)
}

type CrudStore

type CrudStore interface {
	Create(entityType string, originator *common.Originator, payload string) error
	Update(entityType string, originator *common.Originator, payload string) (*common.Originator, error)
	Get(originator *common.Originator, deleted bool) (string, *common.Originator, error)
	Delete(entityType string, originator *common.Originator) (*common.Originator, error)
	List(entityType, fromID string, size int) ([]*common.Originator, string, error)
}

func NewCrudStoreProvider

func NewCrudStoreProvider(ctx context.Context, estore eventstore.Store) (CrudStore, error)

type CrudStoreProvider

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

func (*CrudStoreProvider) Create

func (crud *CrudStoreProvider) Create(entityType string, originator *common.Originator, payload string) error

func (*CrudStoreProvider) Delete

func (crud *CrudStoreProvider) Delete(entityType string, originator *common.Originator) (*common.Originator, error)

func (*CrudStoreProvider) Get

func (crud *CrudStoreProvider) Get(originator *common.Originator, deleted bool) (string, *common.Originator, error)

func (*CrudStoreProvider) List

func (crud *CrudStoreProvider) List(entityType, fromID string, size int) ([]*common.Originator, string, error)

func (*CrudStoreProvider) Update

func (crud *CrudStoreProvider) Update(entityType string, originator *common.Originator, payload string) (*common.Originator, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL