Documentation ¶
Index ¶
- Variables
- func NewEvent(db dal.DB, rds *redis.Client, watch stream.Interface, ...) error
- type Event
- type Flow
- type FlowOptions
- type Key
- func (k Key) DetailKey(cursor string) string
- func (k Key) HeadKey() string
- func (k Key) LockKey() string
- func (k Key) MainHashKey() string
- func (k Key) Name(doc []byte) string
- func (k Key) Namespace() string
- func (k Key) TTLSeconds() int64
- func (k Key) TailKey() string
- func (k Key) Validate(doc []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var BizKey = Key{ // contains filtered or unexported fields }
View Source
var HostKey = Key{ // contains filtered or unexported fields }
View Source
var ModuleHostRelationKey = Key{ // contains filtered or unexported fields }
View Source
var ModuleKey = Key{ // contains filtered or unexported fields }
View Source
var ObjectBaseKey = Key{ // contains filtered or unexported fields }
View Source
var ProcessInstanceRelationKey = Key{ // contains filtered or unexported fields }
View Source
var ProcessKey = Key{ // contains filtered or unexported fields }
View Source
var SetKey = Key{ // contains filtered or unexported fields }
View Source
var SetTemplateKey = Key{ // contains filtered or unexported fields }
Functions ¶
Types ¶
type Flow ¶
type Flow struct { FlowOptions // contains filtered or unexported fields }
type FlowOptions ¶
type FlowOptions struct { Collection string // contains filtered or unexported fields }
type Key ¶
type Key struct {
// contains filtered or unexported fields
}
func GetResourceKeyWithCursorType ¶
func GetResourceKeyWithCursorType(res watch.CursorType) (Key, error)
get resource key
func (Key) DetailKey ¶
Note: do not change the format, it will affect the way in event server to get the details with lua scripts.
func (Key) TTLSeconds ¶
Click to show internal directories.
Click to hide internal directories.