Documentation
¶
Index ¶
- Variables
- type MysqlWorkflowRepository
- func (r *MysqlWorkflowRepository) CreateTrigger(ctx context.Context, trigger *pb.Trigger) (int64, error)
- func (r *MysqlWorkflowRepository) DeleteTriggerByMessageID(ctx context.Context, messageID int64) error
- func (r *MysqlWorkflowRepository) GetTriggerByFlag(ctx context.Context, t, flag string) (pb.Trigger, error)
- func (r *MysqlWorkflowRepository) ListTriggersByType(ctx context.Context, t string) ([]*pb.Trigger, error)
- type WorkflowRepository
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewMysqlWorkflowRepository)
Functions ¶
This section is empty.
Types ¶
type MysqlWorkflowRepository ¶
type MysqlWorkflowRepository struct {
// contains filtered or unexported fields
}
func (*MysqlWorkflowRepository) CreateTrigger ¶
func (*MysqlWorkflowRepository) DeleteTriggerByMessageID ¶
func (r *MysqlWorkflowRepository) DeleteTriggerByMessageID(ctx context.Context, messageID int64) error
func (*MysqlWorkflowRepository) GetTriggerByFlag ¶
func (*MysqlWorkflowRepository) ListTriggersByType ¶
type WorkflowRepository ¶
type WorkflowRepository interface {
GetTriggerByFlag(ctx context.Context, t, flag string) (pb.Trigger, error)
ListTriggersByType(ctx context.Context, t string) ([]*pb.Trigger, error)
CreateTrigger(ctx context.Context, trigger *pb.Trigger) (int64, error)
DeleteTriggerByMessageID(ctx context.Context, messageID int64) error
}
func CreateWorkflowRepository ¶ added in v0.0.24
func CreateWorkflowRepository(id string) (WorkflowRepository, error)
func NewMysqlWorkflowRepository ¶
func NewMysqlWorkflowRepository(id *global.ID, db *mysql.Conn) WorkflowRepository
Source Files
Click to show internal directories.
Click to hide internal directories.