Documentation ¶
Index ¶
- Variables
- type DeleteCommand
- type DeleteFunc
- type DeleteHandler
- type DeletedEvent
- type InsertCommand
- type InsertFunc
- type InsertHandler
- type InsertedEvent
- type QueryFunc
- type QueryHandler
- type Repository
- type RepositoryHandler
- func (rh *RepositoryHandler) AsyncActor() bool
- func (rh *RepositoryHandler) Delete(ctx leikari.ActorContext, cmd DeleteCommand) (*DeletedEvent, error)
- func (rh *RepositoryHandler) Insert(ctx leikari.ActorContext, cmd InsertCommand) (*InsertedEvent, error)
- func (rh *RepositoryHandler) PostStop(ctx leikari.ActorContext) error
- func (rh *RepositoryHandler) PreStart(ctx leikari.ActorContext) error
- func (rh *RepositoryHandler) Query(ctx leikari.ActorContext, qry query.Query) (*query.QueryResult, error)
- func (rh *RepositoryHandler) Receive(ctx leikari.ActorContext, msg leikari.Message)
- func (rh *RepositoryHandler) Select(ctx leikari.ActorContext, cmd SelectCommand) (*SelectedEvent, error)
- func (rh *RepositoryHandler) Update(ctx leikari.ActorContext, cmd UpdateCommand) (*UpdatedEvent, error)
- type RepositoryRef
- type SelectCommand
- type SelectFunc
- type SelectHandler
- type SelectedEvent
- type UpdateCommand
- type UpdateFunc
- type UpdateHandler
- type UpdatedEvent
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type DeleteCommand ¶
type DeleteCommand struct {
Id interface{}
}
type DeleteFunc ¶
type DeleteFunc func(leikari.ActorContext, interface{}) (interface{}, error)
type DeleteHandler ¶
type DeleteHandler interface {
Delete(leikari.ActorContext, DeleteCommand) (*DeletedEvent, error)
}
type DeletedEvent ¶
type InsertCommand ¶
type InsertCommand struct {
Entity interface{}
}
type InsertFunc ¶
type InsertFunc func(leikari.ActorContext, interface{}) (interface{}, error)
type InsertHandler ¶
type InsertHandler interface {
Insert(leikari.ActorContext, InsertCommand) (*InsertedEvent, error)
}
type InsertedEvent ¶
type QueryFunc ¶
type QueryFunc func(leikari.ActorContext, query.Query) (*query.QueryResult, error)
type QueryHandler ¶
type QueryHandler interface {
Query(leikari.ActorContext, query.Query) (*query.QueryResult, error)
}
type Repository ¶
type Repository interface { InsertHandler SelectHandler UpdateHandler DeleteHandler QueryHandler }
func MapRepo ¶
func MapRepo(keyField string) Repository
type RepositoryHandler ¶
type RepositoryHandler struct { OnQuery QueryFunc OnInsert InsertFunc OnSelect SelectFunc OnUpdate UpdateFunc OnDelete DeleteFunc OnStart func(leikari.ActorContext) error OnStop func(leikari.ActorContext) error OnReceive func(leikari.ActorContext, leikari.Message) Sync bool }
func (*RepositoryHandler) AsyncActor ¶
func (rh *RepositoryHandler) AsyncActor() bool
func (*RepositoryHandler) Delete ¶
func (rh *RepositoryHandler) Delete(ctx leikari.ActorContext, cmd DeleteCommand) (*DeletedEvent, error)
func (*RepositoryHandler) Insert ¶
func (rh *RepositoryHandler) Insert(ctx leikari.ActorContext, cmd InsertCommand) (*InsertedEvent, error)
func (*RepositoryHandler) PostStop ¶
func (rh *RepositoryHandler) PostStop(ctx leikari.ActorContext) error
func (*RepositoryHandler) PreStart ¶
func (rh *RepositoryHandler) PreStart(ctx leikari.ActorContext) error
func (*RepositoryHandler) Query ¶
func (rh *RepositoryHandler) Query(ctx leikari.ActorContext, qry query.Query) (*query.QueryResult, error)
func (*RepositoryHandler) Receive ¶
func (rh *RepositoryHandler) Receive(ctx leikari.ActorContext, msg leikari.Message)
func (*RepositoryHandler) Select ¶
func (rh *RepositoryHandler) Select(ctx leikari.ActorContext, cmd SelectCommand) (*SelectedEvent, error)
func (*RepositoryHandler) Update ¶
func (rh *RepositoryHandler) Update(ctx leikari.ActorContext, cmd UpdateCommand) (*UpdatedEvent, error)
type RepositoryRef ¶
type RepositoryRef interface { leikari.Ref Insert(interface{}) (*InsertedEvent, error) InsertContext(context.Context, interface{}) (*InsertedEvent, error) Select(interface{}) (*SelectedEvent, error) SelectContext(context.Context, interface{}) (*SelectedEvent, error) Update(interface{}, interface{}) (*UpdatedEvent, error) UpdateContext(context.Context, interface{}, interface{}) (*UpdatedEvent, error) Delete(interface{}) (*DeletedEvent, error) DeleteContext(context.Context, interface{}) (*DeletedEvent, error) Query(query.Query) (*query.QueryResult, error) QueryContext(context.Context, query.Query) (*query.QueryResult, error) }
func RepositoryService ¶
func RepositoryService(system leikari.ActorExecutor, handler interface{}, name string, opts ...leikari.Option) (RepositoryRef, error)
type SelectCommand ¶
type SelectCommand struct {
Id interface{}
}
type SelectFunc ¶
type SelectFunc func(leikari.ActorContext, interface{}) (interface{}, error)
type SelectHandler ¶
type SelectHandler interface {
Select(leikari.ActorContext, SelectCommand) (*SelectedEvent, error)
}
type SelectedEvent ¶
type UpdateCommand ¶
type UpdateCommand struct { Id interface{} Entity interface{} }
type UpdateFunc ¶
type UpdateFunc func(leikari.ActorContext, interface{}, interface{}) error
type UpdateHandler ¶
type UpdateHandler interface {
Update(leikari.ActorContext, UpdateCommand) (*UpdatedEvent, error)
}
type UpdatedEvent ¶
Click to show internal directories.
Click to hide internal directories.