Documentation ¶
Index ¶
- Variables
- func EntityTypeFromStruct(msg interface{}) string
- func IsDuplicate(err error) bool
- func IsErrDeleted(err error) bool
- func IsErrNotFound(err error) bool
- func NewClient(ctx context.Context, dbUri string) (*clientProvider, error)
- func NewClientWithStore(crudStore CrudStore) *clientProvider
- type Client
- type CrudStore
- type CrudStoreProvider
- func (crud *CrudStoreProvider) Create(entityType string, originator *common.Originator, payload string) error
- func (crud *CrudStoreProvider) Delete(entityType string, originator *common.Originator) (*common.Originator, error)
- func (crud *CrudStoreProvider) Get(originator *common.Originator, deleted bool) (string, *common.Originator, error)
- func (crud *CrudStoreProvider) List(entityType, fromID string, size int) ([]*common.Originator, string, error)
- func (crud *CrudStoreProvider) Update(entityType string, originator *common.Originator, payload string) (*common.Originator, error)
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 IsErrDeleted ¶
func IsErrNotFound ¶
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 ¶
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)
Click to show internal directories.
Click to hide internal directories.