Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

store

package

Go to main page

Versions in this module

v0

v0.19.7

Dec 5, 2024

v0.19.6

Dec 5, 2024

v0.19.5

Dec 1, 2024

v0.19.4

Nov 30, 2024

v0.19.3

Nov 30, 2024

v0.19.2

Nov 30, 2024

v0.19.1

Nov 30, 2024

v0.18.9

Nov 19, 2024

v0.18.8

Nov 13, 2024

v0.18.7

Nov 13, 2024

v0.18.6

Nov 13, 2024

v0.18.5

Nov 13, 2024

v0.18.4

Nov 13, 2024

v0.18.3

Nov 12, 2024

v0.18.2

Nov 12, 2024

v0.18.1

Nov 12, 2024

Changes in this version

type Adapter

+ CreateAgent func(agent *model.Agent) (int64, error)

+ GetAgentByHostid func(uid types.Uid, topic string, hostid string) (*model.Agent, error)

+ GetAgents func() ([]*model.Agent, error)

+ GetLastStepByState func(state model.StepState) (*model.Step, error)

+ UpdateAgentLastOnlineAt func(uid types.Uid, topic string, hostid string, lastOnlineAt time.Time) error

+ UpdateAgentOnlineDuration func(uid types.Uid, topic string, hostid string, offlineTime time.Time) error

v0.13.1

Nov 1, 2024

Changes in this version

type Adapter

+ DeleteJobByIds func(ids []int64) error

+ DeleteStepByJobIds func(jobIds []int64) error

+ ListJobsByFilter func(filter types.JobFilter) ([]*model.Job, error)

v0.12.2

Oct 24, 2024

v0.12.1

Oct 24, 2024

Changes in this version

+ var FS media.Handler

+ func Init()

+ func Migrate() error

+ func RegisterAdapter(a Adapter)

+ func RegisterMediaHandler(name string, mh media.Handler)

+ func UseMediaHandler(name, config string) error

+ type Adapter interface

+ AggregateKeyResultValue func(id int64) error

+ AggregateObjectiveValue func(id int64) error

+ BehaviorGet func(uid types.Uid, flag string) (model.Behavior, error)

+ BehaviorIncrease func(uid types.Uid, flag string, number int) error

+ BehaviorList func(uid types.Uid) ([]*model.Behavior, error)

+ BehaviorSet func(behavior model.Behavior) error

+ Close func() error

+ CompleteTodo func(id int64) error

+ CompleteTodoBySequence func(uid types.Uid, topic string, sequence int64) error

+ ConfigGet func(uid types.Uid, topic, key string) (types.KV, error)

+ ConfigSet func(uid types.Uid, topic, key string, value types.KV) error

+ CreateBot func(bot *model.Bot) (int64, error)

+ CreateChannel func(channel *model.Channel) (int64, error)

+ CreateCounter func(counter *model.Counter) (int64, error)

+ CreateCycle func(cycle *model.Cycle) (int64, error)

+ CreateInstruct func(instruct *model.Instruct) (int64, error)

+ CreateJob func(item *model.Job) (int64, error)

+ CreateKeyResult func(keyResult *model.KeyResult) (int64, error)

+ CreateKeyResultValue func(keyResultValue *model.KeyResultValue) (int64, error)

+ CreateMessage func(message model.Message) error

+ CreateObjective func(objective *model.Objective) (int64, error)

+ CreatePlatform func(platform *model.Platform) (int64, error)

+ CreatePlatformChannel func(item *model.PlatformChannel) (int64, error)

+ CreatePlatformChannelUser func(item *model.PlatformChannelUser) (int64, error)

+ CreatePlatformUser func(item *model.PlatformUser) (int64, error)

+ CreateReview func(review *model.Review) (int64, error)

+ CreateReviewEvaluation func(evaluation *model.ReviewEvaluation) (int64, error)

+ CreateStep func(step *model.Step) (int64, error)

+ CreateSteps func(steps []*model.Step) error

+ CreateTodo func(todo *model.Todo) (int64, error)

+ CreateWebhook func(webhook *model.Webhook) (int64, error)

+ CreateWorkflow func(workflow *model.Workflow, script *model.WorkflowScript, dag *model.Dag, ...) (int64, error)

+ CreateWorkflowScript func(item *model.WorkflowScript) (int64, error)

+ CreateWorkflowTrigger func(item *model.WorkflowTrigger) (int64, error)

+ DataDelete func(uid types.Uid, topic, key string) error

+ DataGet func(uid types.Uid, topic, key string) (types.KV, error)

+ DataList func(uid types.Uid, topic string, filter types.DataFilter) ([]*model.Data, error)

+ DataSet func(uid types.Uid, topic, key string, value types.KV) error

+ DecreaseCounter func(id, amount int64) error

+ DeleteBot func(name string) error

+ DeleteChannel func(name string) error

+ DeleteJob func(id int64) error

+ DeleteKeyResult func(id int64) error

+ DeleteKeyResultBySequence func(uid types.Uid, topic string, sequence int64) error

+ DeleteKeyResultValue func(id int64) error

+ DeleteObjective func(id int64) error

+ DeleteObjectiveBySequence func(uid types.Uid, topic string, sequence int64) error

+ DeleteTodo func(id int64) error

+ DeleteTodoBySequence func(uid types.Uid, topic string, sequence int64) error

+ DeleteWebhook func(id int64) error

+ DeleteWorkflow func(id int64) error

+ DeleteWorkflowTrigger func(id int64) error

+ FileDeleteUnused func(olderThan time.Time, limit int) ([]string, error)

+ FileFinishUpload func(fd *types.FileDef, success bool, size int64) (*types.FileDef, error)

+ FileGet func(fid string) (*types.FileDef, error)

+ FileStartUpload func(fd *types.FileDef) error

+ FormGet func(formId string) (model.Form, error)

+ FormSet func(formId string, form model.Form) error

+ GetBot func(id int64) (*model.Bot, error)

+ GetBotByName func(name string) (*model.Bot, error)

+ GetBots func() ([]*model.Bot, error)

+ GetChannel func(id int64) (*model.Channel, error)

+ GetChannelByName func(name string) (*model.Channel, error)

+ GetChannels func() ([]*model.Channel, error)

+ GetCounter func(id int64) (model.Counter, error)

+ GetCounterByFlag func(uid types.Uid, topic string, flag string) (model.Counter, error)

+ GetCycleByID func(id int64) (*model.Cycle, error)

+ GetDB func() *gorm.DB

+ GetDag func(id int64) (*model.Dag, error)

+ GetJob func(id int64) (*model.Job, error)

+ GetJobsByState func(state model.JobState) ([]*model.Job, error)

+ GetJobsByStates func(states []model.JobState) ([]*model.Job, error)

+ GetJobsByWorkflowId func(workflowID int64) ([]*model.Job, error)

+ GetKeyResultByID func(id int64) (*model.KeyResult, error)

+ GetKeyResultBySequence func(uid types.Uid, topic string, sequence int64) (*model.KeyResult, error)

+ GetKeyResultValue func(id int64) (*model.KeyResultValue, error)

+ GetKeyResultValues func(keyResultId int64) ([]*model.KeyResultValue, error)

+ GetMessage func(flag string) (*model.Message, error)

+ GetMessageByPlatform func(platformId int64, platformMsgId string) (*model.Message, error)

+ GetName func() string

+ GetObjectiveByID func(id int64) (*model.Objective, error)

+ GetObjectiveBySequence func(uid types.Uid, topic string, sequence int64) (*model.Objective, error)

+ GetPlatform func(id int64) (*model.Platform, error)

+ GetPlatformByName func(name string) (*model.Platform, error)

+ GetPlatformChannelByFlag func(flag string) (*model.PlatformChannel, error)

+ GetPlatformChannelUsersByUserFlag func(userFlag string) ([]*model.PlatformChannelUser, error)

+ GetPlatformChannelsByChannelId func(channelId int64) (*model.PlatformChannel, error)

+ GetPlatformChannelsByPlatformIds func(platformIds []int64) ([]*model.PlatformChannel, error)

+ GetPlatformUserByFlag func(flag string) (*model.PlatformUser, error)

+ GetPlatformUsersByUserId func(userId int64) ([]*model.PlatformUser, error)

+ GetPlatforms func() ([]*model.Platform, error)

+ GetReviewByID func(id int64) (*model.Review, error)

+ GetReviewEvaluationByID func(id int64) (*model.ReviewEvaluation, error)

+ GetStepsByDepend func(jobId int64, depend []string) ([]*model.Step, error)

+ GetStepsByJobId func(jobId int64) ([]*model.Step, error)

+ GetStepsByState func(state model.StepState) ([]*model.Step, error)

+ GetTodo func(id int64) (*model.Todo, error)

+ GetTodoBySequence func(uid types.Uid, topic string, sequence int64) (*model.Todo, error)

+ GetUserByFlag func(flag string) (*model.User, error)

+ GetUserById func(id int64) (*model.User, error)

+ GetUsers func() ([]*model.User, error)

+ GetWebhookBySecret func(secret string) (*model.Webhook, error)

+ GetWebhookByUidAndFlag func(uid types.Uid, flag string) (*model.Webhook, error)

+ GetWorkflow func(id int64) (*model.Workflow, error)

+ GetWorkflowScript func(id int64) (any, error)

+ GetWorkflowScriptByWorkflowId func(workflowId int64) (any, error)

+ IncreaseCounter func(id, amount int64) error

+ IncreaseWebhookCount func(id int64) error

+ IncreaseWorkflowCount func(id int64, successful int32, failed int32, running int32, canceled int32) error

+ IncreaseWorkflowTriggerCount func(id int64, count int32) error

+ IsOpen func() bool

+ ListCounter func(uid types.Uid, topic string) ([]*model.Counter, error)

+ ListCycles func(uid types.Uid, topic string) ([]*model.Cycle, error)

+ ListInstruct func(uid types.Uid, isExpire bool) ([]*model.Instruct, error)

+ ListJobs func(workflowID int64) ([]*model.Job, error)

+ ListKeyResults func(uid types.Uid, topic string) ([]*model.KeyResult, error)

+ ListKeyResultsById func(id []int64) ([]*model.KeyResult, error)

+ ListKeyResultsByObjectiveId func(objectiveId int64) ([]*model.KeyResult, error)

+ ListObjectives func(uid types.Uid, topic string) ([]*model.Objective, error)

+ ListRemindTodos func(uid types.Uid, topic string) ([]*model.Todo, error)

+ ListReviewEvaluations func(uid types.Uid, topic string, reviewID int64) ([]*model.ReviewEvaluation, error)

+ ListReviews func(uid types.Uid, topic string) ([]*model.Review, error)

+ ListTodos func(uid types.Uid, topic string) ([]*model.Todo, error)

+ ListWebhook func(uid types.Uid) ([]*model.Webhook, error)

+ ListWorkflowTriggerByType func(t model.TriggerType) ([]*model.WorkflowTrigger, error)

+ ListWorkflows func(uid types.Uid, topic string) ([]*model.Workflow, error)

+ OAuthGet func(uid types.Uid, topic, t string) (model.OAuth, error)

+ OAuthGetAvailable func(t string) ([]model.OAuth, error)

+ OAuthSet func(oauth model.OAuth) error

+ Open func(config config.StoreType) error

+ PageGet func(pageId string) (model.Page, error)

+ PageSet func(pageId string, page model.Page) error

+ ParameterDelete func(flag string) error

+ ParameterGet func(flag string) (model.Parameter, error)

+ ParameterSet func(flag string, params types.KV, expiredAt time.Time) error

+ Stats func() interface{}

+ UpdateBot func(bot *model.Bot) error

+ UpdateChannel func(channel *model.Channel) error

+ UpdateCycle func(cycle *model.Cycle) error

+ UpdateDag func(item *model.Dag) error

+ UpdateInstruct func(instruct *model.Instruct) error

+ UpdateJobState func(id int64, state model.JobState) error

+ UpdateKeyResult func(keyResult *model.KeyResult) error

+ UpdateObjective func(objective *model.Objective) error

+ UpdatePlatformUser func(item *model.PlatformUser) error

+ UpdateReview func(review *model.Review) error

+ UpdateReviewEvaluation func(evaluation *model.ReviewEvaluation) error

+ UpdateStep func(id int64, item *model.Step) error

+ UpdateStepInput func(id int64, input types.KV) error

+ UpdateStepOutput func(id int64, output types.KV) error

+ UpdateStepState func(id int64, state model.StepState) error

+ UpdateTodo func(todo *model.Todo) error

+ UpdateWebhook func(webhook *model.Webhook) error

+ UpdateWorkflow func(workflow *model.Workflow, script *model.WorkflowScript, dag *model.Dag, ...) error

+ UpdateWorkflowState func(id int64, state model.WorkflowState) error

+ UpdateWorkflowTrigger func(item *model.WorkflowTrigger) error

+ UserCreate func(user *model.User) error

+ UserDelete func(uid types.Uid, hard bool) error

+ UserGet func(uid types.Uid) (*model.User, error)

+ UserGetAll func(ids ...types.Uid) ([]*model.User, error)

+ UserUpdate func(uid types.Uid, update types.KV) error

+ var Database Adapter

+ type PersistentStorageInterface interface

+ Close func() error

+ DbStats func() func() interface{}

+ GetAdapter func() Adapter

+ IsOpen func() bool

+ Open func(jsonConfig config.StoreType) error

+ var Store PersistentStorageInterface