model

package
v0.0.0-...-e652847 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 15, 2020 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// AccountName is the Name field name
	AccountName = "Name"
	// AccountNameColumnName is the Name field associated column name
	AccountNameColumnName = "name"
	// AccountType is the Type field name
	AccountType = "Type"
	// AccountTypeColumnName is the Type field associated column name
	AccountTypeColumnName = "type"
	// AccountStatus is the Status field name
	AccountStatus = "Status"
	// AccountStatusColumnName is the Status field associated column name
	AccountStatusColumnName = "status"
	// AccountCSR is the CSR field name
	AccountCSR = "CSR"
	// AccountCSRColumnName is the CSR field associated column name
	AccountCSRColumnName = "csr"
	// AccountCSROrigin is the CSROrigin field name
	AccountCSROrigin = "CSROrigin"
	// AccountCSROriginColumnName is the CSROrigin field associated column name
	AccountCSROriginColumnName = "csr_origin"
	// AccountCert is the Cert field name
	AccountCert = "Cert"
	// AccountCertColumnName is the Cert field associated column name
	AccountCertColumnName = "cert"
	// AccountAPIKey is the APIKey field name
	AccountAPIKey = "APIKey"
	// AccountAPIKeyColumnName is the APIKey field associated column name
	AccountAPIKeyColumnName = "api_key"
)
View Source 
const (
	// ActorName is the Name field name
	ActorName = "Name"
	// ActorNameColumnName is the Name field associated column name
	ActorNameColumnName = "name"
	// ActorAccountID is the AccountID field name
	ActorAccountID = "AccountID"
	// ActorAccountIDColumnName is the AccountID field associated column name
	ActorAccountIDColumnName = "account_id"
	// ActorKind is the Kind field name
	ActorKind = "Kind"
	// ActorKindColumnName is the Kind field associated column name
	ActorKindColumnName = "kind"
	// ActorRole is the Role field name
	ActorRole = "Role"
	// ActorRoleColumnName is the Role field associated column name
	ActorRoleColumnName = "role"
	// ActorStatus is the Status field name
	ActorStatus = "Status"
	// ActorStatusColumnName is the Status field associated column name
	ActorStatusColumnName = "status"
	// ActorOnline is the Online field name
	ActorOnline = "Online"
	// ActorOnlineColumnName is the Online field associated column name
	ActorOnlineColumnName = "online"
	// ActorUnresponsive is the Unresponsive field name
	ActorUnresponsive = "Unresponsive"
	// ActorUnresponsiveColumnName is the Unresponsive field associated column name
	ActorUnresponsiveColumnName = "unresponsive"
	// ActorLastSeen is the LastSeen field name
	ActorLastSeen = "LastSeen"
	// ActorLastSeenColumnName is the LastSeen field associated column name
	ActorLastSeenColumnName = "last_seen"
	// ActorConfig is the Config field name
	ActorConfig = "Config"
	// ActorConfigColumnName is the Config field associated column name
	ActorConfigColumnName = "config"
)
View Source 
const (
	// BaseID is the ID field name
	BaseID = "ID"
	// BaseIDColumnName is the ID field associated column name
	BaseIDColumnName = "id"
	// BaseCreatedAt is the CreatedAt field name
	BaseCreatedAt = "CreatedAt"
	// BaseCreatedAtColumnName is the CreatedAt field associated column name
	BaseCreatedAtColumnName = "created_at"
	// BaseUpdatedAt is the UpdatedAt field name
	BaseUpdatedAt = "UpdatedAt"
	// BaseUpdatedAtColumnName is the UpdatedAt field associated column name
	BaseUpdatedAtColumnName = "updated_at"
)
View Source 
const (
	// EnvelopeTypesKnown is the TypesKnown field name
	EnvelopeTypesKnown = "TypesKnown"
	// EnvelopeTypesKnownColumnName is the TypesKnown field associated column name
	EnvelopeTypesKnownColumnName = "types_known"
	// EnvelopeEventIDs is the EventIDs field name
	EnvelopeEventIDs = "EventIDs"
	// EnvelopeEventIDsColumnName is the EventIDs field associated column name
	EnvelopeEventIDsColumnName = "event_ids"
	// EnvelopeStatus is the Status field name
	EnvelopeStatus = "Status"
	// EnvelopeStatusColumnName is the Status field associated column name
	EnvelopeStatusColumnName = "status"
	// EnvelopeError is the Error field name
	EnvelopeError = "Error"
	// EnvelopeErrorColumnName is the Error field associated column name
	EnvelopeErrorColumnName = "error"
)
View Source 
const (
	// EventID is the ID field name
	EventID = "ID"
	// EventIDColumnName is the ID field associated column name
	EventIDColumnName = "id"
	// EventEnvelopeID is the EnvelopeID field name
	EventEnvelopeID = "EnvelopeID"
	// EventEnvelopeIDColumnName is the EnvelopeID field associated column name
	EventEnvelopeIDColumnName = "envelope_id"
	// EventEventID is the EventID field name
	EventEventID = "EventID"
	// EventEventIDColumnName is the EventID field associated column name
	EventEventIDColumnName = "event_id"
	// EventEventType is the EventType field name
	EventEventType = "EventType"
	// EventEventTypeColumnName is the EventType field associated column name
	EventEventTypeColumnName = "event_type"
	// EventStatus is the Status field name
	EventStatus = "Status"
	// EventStatusColumnName is the Status field associated column name
	EventStatusColumnName = "status"
	// EventItemCount is the ItemCount field name
	EventItemCount = "ItemCount"
	// EventItemCountColumnName is the ItemCount field associated column name
	EventItemCountColumnName = "item_count"
	// EventChecksum is the Checksum field name
	EventChecksum = "Checksum"
	// EventChecksumColumnName is the Checksum field associated column name
	EventChecksumColumnName = "checksum"
	// EventValidator is the Validator field name
	EventValidator = "Validator"
	// EventValidatorColumnName is the Validator field associated column name
	EventValidatorColumnName = "validator"
)
View Source 
const (
	// ItemID is the ID field name
	ItemID = "ID"
	// ItemIDColumnName is the ID field associated column name
	ItemIDColumnName = "id"
	// ItemEventID is the EventID field name
	ItemEventID = "EventID"
	// ItemEventIDColumnName is the EventID field associated column name
	ItemEventIDColumnName = "event_id"
	// ItemBatch is the Batch field name
	ItemBatch = "Batch"
	// ItemBatchColumnName is the Batch field associated column name
	ItemBatchColumnName = "batch"
	// ItemIndex is the Index field name
	ItemIndex = "Index"
	// ItemIndexColumnName is the Index field associated column name
	ItemIndexColumnName = "index_"
	// ItemData is the Data field name
	ItemData = "Data"
	// ItemDataColumnName is the Data field associated column name
	ItemDataColumnName = "data"
)
View Source 
const (
	// LogEntryID is the ID field name
	LogEntryID = "ID"
	// LogEntryIDColumnName is the ID field associated column name
	LogEntryIDColumnName = "id"
	// LogEntryEnvelopeID is the EnvelopeID field name
	LogEntryEnvelopeID = "EnvelopeID"
	// LogEntryEnvelopeIDColumnName is the EnvelopeID field associated column name
	LogEntryEnvelopeIDColumnName = "envelope_id"
	// LogEntryActorID is the ActorID field name
	LogEntryActorID = "ActorID"
	// LogEntryActorIDColumnName is the ActorID field associated column name
	LogEntryActorIDColumnName = "actor_id"
	// LogEntryProcessID is the ProcessID field name
	LogEntryProcessID = "ProcessID"
	// LogEntryProcessIDColumnName is the ProcessID field associated column name
	LogEntryProcessIDColumnName = "process_id"
	// LogEntryNodeID is the NodeID field name
	LogEntryNodeID = "NodeID"
	// LogEntryNodeIDColumnName is the NodeID field associated column name
	LogEntryNodeIDColumnName = "node_id"
	// LogEntryTime is the Time field name
	LogEntryTime = "Time"
	// LogEntryTimeColumnName is the Time field associated column name
	LogEntryTimeColumnName = "time"
	// LogEntryLevel is the Level field name
	LogEntryLevel = "Level"
	// LogEntryLevelColumnName is the Level field associated column name
	LogEntryLevelColumnName = "level"
	// LogEntryText is the Text field name
	LogEntryText = "Text"
	// LogEntryTextColumnName is the Text field associated column name
	LogEntryTextColumnName = "text"
)
View Source 
const (
	// PipelineName is the Name field name
	PipelineName = "Name"
	// PipelineNameColumnName is the Name field associated column name
	PipelineNameColumnName = "name"
	// PipelineVersion is the Version field name
	PipelineVersion = "Version"
	// PipelineVersionColumnName is the Version field associated column name
	PipelineVersionColumnName = "version"
	// PipelineStatus is the Status field name
	PipelineStatus = "Status"
	// PipelineStatusColumnName is the Status field associated column name
	PipelineStatusColumnName = "status"
	// PipelineEdges is the Edges field name
	PipelineEdges = "Edges"
	// PipelineEdgesColumnName is the Edges field associated column name
	PipelineEdgesColumnName = "edges"
)
View Source 
const (
	// GraphNodeID is the ID field name
	GraphNodeID = "ID"
	// GraphNodeIDColumnName is the ID field associated column name
	GraphNodeIDColumnName = "id"
	// GraphNodePipelineID is the PipelineID field name
	GraphNodePipelineID = "PipelineID"
	// GraphNodePipelineIDColumnName is the PipelineID field associated column name
	GraphNodePipelineIDColumnName = "pipeline_id"
	// GraphNodeNodeID is the NodeID field name
	GraphNodeNodeID = "NodeID"
	// GraphNodeNodeIDColumnName is the NodeID field associated column name
	GraphNodeNodeIDColumnName = "node_id"
	// GraphNodeType is the Type field name
	GraphNodeType = "Type"
	// GraphNodeTypeColumnName is the Type field associated column name
	GraphNodeTypeColumnName = "type"
	// GraphNodeActorIDs is the ActorIDs field name
	GraphNodeActorIDs = "ActorIDs"
	// GraphNodeActorIDsColumnName is the ActorIDs field associated column name
	GraphNodeActorIDsColumnName = "actor_ids"
	// GraphNodeActors is the Actors field name
	GraphNodeActors = "Actors"
	// GraphNodeActorsColumnName is the Actors field associated column name
	GraphNodeActorsColumnName = "actors"
	// GraphNodeRoles is the Roles field name
	GraphNodeRoles = "Roles"
	// GraphNodeRolesColumnName is the Roles field associated column name
	GraphNodeRolesColumnName = "roles"
	// GraphNodeRoleBroadcast is the RoleBroadcast field name
	GraphNodeRoleBroadcast = "RoleBroadcast"
	// GraphNodeRoleBroadcastColumnName is the RoleBroadcast field associated column name
	GraphNodeRoleBroadcastColumnName = "role_broadcast"
	// GraphNodeSourceMatchEventTypes is the SourceMatchEventTypes field name
	GraphNodeSourceMatchEventTypes = "SourceMatchEventTypes"
	// GraphNodeSourceMatchEventTypesColumnName is the SourceMatchEventTypes field associated column name
	GraphNodeSourceMatchEventTypesColumnName = "source_match_event_types"
	// GraphNodeInputs is the Inputs field name
	GraphNodeInputs = "Inputs"
	// GraphNodeInputsColumnName is the Inputs field associated column name
	GraphNodeInputsColumnName = "inputs"
	// GraphNodeOutputs is the Outputs field name
	GraphNodeOutputs = "Outputs"
	// GraphNodeOutputsColumnName is the Outputs field associated column name
	GraphNodeOutputsColumnName = "outputs"
)
View Source 
const (
	// ProcessTriggerEmitterID is the TriggerEmitterID field name
	ProcessTriggerEmitterID = "TriggerEmitterID"
	// ProcessTriggerEmitterIDColumnName is the TriggerEmitterID field associated column name
	ProcessTriggerEmitterIDColumnName = "trigger_emitter_id"
	// ProcessTriggerEnvelopeID is the TriggerEnvelopeID field name
	ProcessTriggerEnvelopeID = "TriggerEnvelopeID"
	// ProcessTriggerEnvelopeIDColumnName is the TriggerEnvelopeID field associated column name
	ProcessTriggerEnvelopeIDColumnName = "trigger_envelope_id"
	// ProcessPipelineID is the PipelineID field name
	ProcessPipelineID = "PipelineID"
	// ProcessPipelineIDColumnName is the PipelineID field associated column name
	ProcessPipelineIDColumnName = "pipeline_id"
	// ProcessSourceNodeID is the SourceNodeID field name
	ProcessSourceNodeID = "SourceNodeID"
	// ProcessSourceNodeIDColumnName is the SourceNodeID field associated column name
	ProcessSourceNodeIDColumnName = "source_node_id"
	// ProcessSourceSlotID is the SourceSlotID field name
	ProcessSourceSlotID = "SourceSlotID"
	// ProcessSourceSlotIDColumnName is the SourceSlotID field associated column name
	ProcessSourceSlotIDColumnName = "source_slot_id"
)
View Source 
const (
	// RouteID is the ID field name
	RouteID = "ID"
	// RouteIDColumnName is the ID field associated column name
	RouteIDColumnName = "id"
	// RouteProcessID is the ProcessID field name
	RouteProcessID = "ProcessID"
	// RouteProcessIDColumnName is the ProcessID field associated column name
	RouteProcessIDColumnName = "process_id"
	// RouteSource is the Source field name
	RouteSource = "Source"
	// RouteSourceColumnName is the Source field associated column name
	RouteSourceColumnName = "source"
	// RouteEnvelopeID is the EnvelopeID field name
	RouteEnvelopeID = "EnvelopeID"
	// RouteEnvelopeIDColumnName is the EnvelopeID field associated column name
	RouteEnvelopeIDColumnName = "envelope_id"
)
View Source 
const (
	// RouteTargetID is the ID field name
	RouteTargetID = "ID"
	// RouteTargetIDColumnName is the ID field associated column name
	RouteTargetIDColumnName = "id"
	// RouteTargetRouteID is the RouteID field name
	RouteTargetRouteID = "RouteID"
	// RouteTargetRouteIDColumnName is the RouteID field associated column name
	RouteTargetRouteIDColumnName = "route_id"
	// RouteTargetActorID is the ActorID field name
	RouteTargetActorID = "ActorID"
	// RouteTargetActorIDColumnName is the ActorID field associated column name
	RouteTargetActorIDColumnName = "actor_id"
	// RouteTargetNodeID is the NodeID field name
	RouteTargetNodeID = "NodeID"
	// RouteTargetNodeIDColumnName is the NodeID field associated column name
	RouteTargetNodeIDColumnName = "node_id"
	// RouteTargetInput is the Input field name
	RouteTargetInput = "Input"
	// RouteTargetInputColumnName is the Input field associated column name
	RouteTargetInputColumnName = "input"
)
View Source 
const (
	// ProcessLogEntryID is the ID field name
	ProcessLogEntryID = "ID"
	// ProcessLogEntryIDColumnName is the ID field associated column name
	ProcessLogEntryIDColumnName = "id"
	// ProcessLogEntryTimestamp is the Timestamp field name
	ProcessLogEntryTimestamp = "Timestamp"
	// ProcessLogEntryTimestampColumnName is the Timestamp field associated column name
	ProcessLogEntryTimestampColumnName = "timestamp"
	// ProcessLogEntryProcessID is the ProcessID field name
	ProcessLogEntryProcessID = "ProcessID"
	// ProcessLogEntryProcessIDColumnName is the ProcessID field associated column name
	ProcessLogEntryProcessIDColumnName = "process_id"
	// ProcessLogEntryData is the Data field name
	ProcessLogEntryData = "Data"
	// ProcessLogEntryDataColumnName is the Data field associated column name
	ProcessLogEntryDataColumnName = "data"
	// ProcessLogEntryLogProcessed is the LogProcessed field name
	ProcessLogEntryLogProcessed = "LogProcessed"
	// ProcessLogEntryLogProcessedColumnName is the LogProcessed field associated column name
	ProcessLogEntryLogProcessedColumnName = "log_processed"
	// ProcessLogEntryProcessingError is the ProcessingError field name
	ProcessLogEntryProcessingError = "ProcessingError"
	// ProcessLogEntryProcessingErrorColumnName is the ProcessingError field associated column name
	ProcessLogEntryProcessingErrorColumnName = "processing_error"
)
View Source 
const (
	// ProcessStateProcessID is the ProcessID field name
	ProcessStateProcessID = "ProcessID"
	// ProcessStateProcessIDColumnName is the ProcessID field associated column name
	ProcessStateProcessIDColumnName = "process_id"
	// ProcessStateStatus is the Status field name
	ProcessStateStatus = "Status"
	// ProcessStateStatusColumnName is the Status field associated column name
	ProcessStateStatusColumnName = "status"
	// ProcessStateStatusChanged is the StatusChanged field name
	ProcessStateStatusChanged = "StatusChanged"
	// ProcessStateStatusChangedColumnName is the StatusChanged field associated column name
	ProcessStateStatusChangedColumnName = "status_changed"
	// ProcessStateStatusReason is the StatusReason field name
	ProcessStateStatusReason = "StatusReason"
	// ProcessStateStatusReasonColumnName is the StatusReason field associated column name
	ProcessStateStatusReasonColumnName = "status_reason"
	// ProcessStateNodeStates is the NodeStates field name
	ProcessStateNodeStates = "NodeStates"
	// ProcessStateNodeStatesColumnName is the NodeStates field associated column name
	ProcessStateNodeStatesColumnName = "node_states"
	// ProcessStateNodeStatesChanged is the NodeStatesChanged field name
	ProcessStateNodeStatesChanged = "NodeStatesChanged"
	// ProcessStateNodeStatesChangedColumnName is the NodeStatesChanged field associated column name
	ProcessStateNodeStatesChangedColumnName = "node_states_changed"
	// ProcessStateResponse is the Response field name
	ProcessStateResponse = "Response"
	// ProcessStateResponseColumnName is the Response field associated column name
	ProcessStateResponseColumnName = "response"
	// ProcessStateResultAcked is the ResultAcked field name
	ProcessStateResultAcked = "ResultAcked"
	// ProcessStateResultAckedColumnName is the ResultAcked field associated column name
	ProcessStateResultAckedColumnName = "result_acked"
	// ProcessStatePMLevel is the PMLevel field name
	ProcessStatePMLevel = "PMLevel"
	// ProcessStatePMLevelColumnName is the PMLevel field associated column name
	ProcessStatePMLevelColumnName = "pm_level"
	// ProcessStatePMStatus is the PMStatus field name
	ProcessStatePMStatus = "PMStatus"
	// ProcessStatePMStatusColumnName is the PMStatus field associated column name
	ProcessStatePMStatusColumnName = "pm_status"
	// ProcessStatePMComment is the PMComment field name
	ProcessStatePMComment = "PMComment"
	// ProcessStatePMCommentColumnName is the PMComment field associated column name
	ProcessStatePMCommentColumnName = "pm_comment"
	// ProcessStatePMChanged is the PMChanged field name
	ProcessStatePMChanged = "PMChanged"
	// ProcessStatePMChangedColumnName is the PMChanged field associated column name
	ProcessStatePMChangedColumnName = "pm_changed"
)
View Source 
const (
	// AccountTableName is the Account associated table name
	AccountTableName = "account"
)
View Source 
const (
	// ActorTableName is the Actor associated table name
	ActorTableName = "actor"
)
View Source 
const (
	// EnvelopeTableName is the Envelope associated table name
	EnvelopeTableName = "envelope"
)
View Source 
const (
	// EventTableName is the Event associated table name
	EventTableName = "event"
)
View Source 
const (
	// GraphNodeTableName is the GraphNode associated table name
	GraphNodeTableName = "graph_node"
)
View Source 
const (
	// ItemTableName is the Item associated table name
	ItemTableName = "item"
)
View Source 
const (
	// LogEntryTableName is the LogEntry associated table name
	LogEntryTableName = "log_entry"
)
View Source 
const (
	// PipelineTableName is the Pipeline associated table name
	PipelineTableName = "pipeline"
)
View Source 
const (
	// ProcessLogEntryTableName is the ProcessLogEntry associated table name
	ProcessLogEntryTableName = "process_log_entry"
)
View Source 
const (
	// ProcessStateTableName is the ProcessState associated table name
	ProcessStateTableName = "process_state"
)
View Source 
const (
	// ProcessTableName is the Process associated table name
	ProcessTableName = "process"
)
View Source 
const (
	// RouteTableName is the Route associated table name
	RouteTableName = "route"
)
View Source 
const (
	// RouteTargetTableName is the RouteTarget associated table name
	RouteTargetTableName = "route_target"
)

Variables

This section is empty.

Functions

func ActorListToAPI 

func ActorListToAPI(actors []Actor) (res []api.Actor)

ActorListToAPI converts a []Actor to []api.Actor

Types

type Account 

type Account struct {
	Base
	Name      string                `yago:"unique_index=name"`
	Type      api.Account_Type      `yago:"textmarshaled"`
	Status    api.Account_Status    `yago:"textmarshaled"`
	CSR       string                `yago:"type=qb.Text()"`
	CSROrigin api.Account_CSROrigin `yago:"textmarshaled"`
	Cert      string                `yago:"type=qb.Text()"`
	APIKey    string                `yago:"."`
}

Account holds identification information to let one connect to Xbus. yago:

func AccountFromAPIActor 

func AccountFromAPIActor(actor api.Actor) Account

AccountFromAPIActor provides a model.Account from an api.Actor. It is assumed the account and the actor have the same name. TODO To be reworked once we have an api.Account.

func (Account) StructType 

func (Account) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type AccountMapper 

type AccountMapper struct{}

AccountMapper is the Account mapper

func NewAccountMapper 

func NewAccountMapper() *AccountMapper

NewAccountMapper initialize a NewAccountMapper

func (AccountMapper) AutoIncrementPKey 

func (AccountMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (AccountMapper) FieldList 

func (mapper AccountMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*AccountMapper) GetMapper 

func (mapper *AccountMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (AccountMapper) LoadAutoIncrementPKeyValue 

func (AccountMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*AccountMapper) Name 

func (*AccountMapper) Name() string

Name returns the mapper name

func (AccountMapper) PKey 

func (mapper AccountMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (AccountMapper) PKeyClause 

func (mapper AccountMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (AccountMapper) SQLValues 

func (mapper AccountMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (AccountMapper) Scan 

func (mapper AccountMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (AccountMapper) ScanPKey 

func (mapper AccountMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (AccountMapper) StructType 

func (AccountMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*AccountMapper) Table 

func (*AccountMapper) Table() *qb.TableElem

Table returns the mapper table

type AccountModel 

type AccountModel struct {
	Name      yago.ScalarField
	Type      yago.MarshaledScalarField
	Status    yago.MarshaledScalarField
	CSR       yago.ScalarField
	CSROrigin yago.MarshaledScalarField
	Cert      yago.ScalarField
	APIKey    yago.ScalarField
	ID        yago.ScalarField
	CreatedAt yago.ScalarField
	UpdatedAt yago.ScalarField
	// contains filtered or unexported fields
}

AccountModel provides direct access to helpers for Account queries

func NewAccountModel 

func NewAccountModel(meta *yago.Metadata) AccountModel

NewAccountModel returns a new AccountModel

func (AccountModel) GetMapper 

func (m AccountModel) GetMapper() yago.Mapper

GetMapper returns the associated AccountMapper instance

type Actor 

type Actor struct {
	Base
	Name      string           `yago:"unique_index=name"`
	AccountID uuid.NullUUID    `yago:"fk=Account ONDELETE SET NULL"`
	Kind      api.Actor_Kind   `yago:"textmarshaled"`
	Role      string           `yago:"."`
	Status    api.Actor_Status `yago:"textmarshaled"`

	Online       bool      `yago:"."`
	Unresponsive bool      `yago:"."`
	LastSeen     time.Time `yago:"."`

	Config string `yago:"."`
}

Actor is any client of the bus (emitter, consumer, worker) yago:

func ActorFromAPI 

func ActorFromAPI(actor api.Actor) Actor

ActorFromAPI convert a api.Actor to model.Actor

func (Actor) StructType 

func (Actor) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

func (Actor) ToAPI 

func (a Actor) ToAPI() api.Actor

ToAPI convert the actor to a api.Actor

type ActorMapper 

type ActorMapper struct{}

ActorMapper is the Actor mapper

func NewActorMapper 

func NewActorMapper() *ActorMapper

NewActorMapper initialize a NewActorMapper

func (ActorMapper) AutoIncrementPKey 

func (ActorMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (ActorMapper) FieldList 

func (mapper ActorMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*ActorMapper) GetMapper 

func (mapper *ActorMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (ActorMapper) LoadAutoIncrementPKeyValue 

func (ActorMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*ActorMapper) Name 

func (*ActorMapper) Name() string

Name returns the mapper name

func (ActorMapper) PKey 

func (mapper ActorMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (ActorMapper) PKeyClause 

func (mapper ActorMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (ActorMapper) SQLValues 

func (mapper ActorMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (ActorMapper) Scan 

func (mapper ActorMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (ActorMapper) ScanPKey 

func (mapper ActorMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (ActorMapper) StructType 

func (ActorMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*ActorMapper) Table 

func (*ActorMapper) Table() *qb.TableElem

Table returns the mapper table

type ActorModel 

type ActorModel struct {
	Name         yago.ScalarField
	AccountID    yago.ScalarField
	Kind         yago.MarshaledScalarField
	Role         yago.ScalarField
	Status       yago.MarshaledScalarField
	Online       yago.ScalarField
	Unresponsive yago.ScalarField
	LastSeen     yago.ScalarField
	Config       yago.ScalarField
	ID           yago.ScalarField
	CreatedAt    yago.ScalarField
	UpdatedAt    yago.ScalarField
	// contains filtered or unexported fields
}

ActorModel provides direct access to helpers for Actor queries

func NewActorModel 

func NewActorModel(meta *yago.Metadata) ActorModel

NewActorModel returns a new ActorModel

func (ActorModel) GetMapper 

func (m ActorModel) GetMapper() yago.Mapper

GetMapper returns the associated ActorMapper instance

type Base 

type Base struct {
	ID        uuid.UUID `yago:"primary_key"`
	CreatedAt time.Time
	UpdatedAt NullTime `yago:"type=qb.Timestamp()"`
}

Base struct for the Xbus broker database models.

func (*Base) BeforeInsert 

func (m *Base) BeforeInsert(db *yago.DB)

BeforeInsert callback

func (*Base) BeforeUpdate 

func (m *Base) BeforeUpdate(db *yago.DB)

BeforeUpdate callback

type Envelope 

type Envelope struct {
	Base
	TypesKnown bool
	EventIDs   string                                 `yago:"type=qb.Text()"`
	Status     storage.EnvelopeStorageReceptionStatus `yago:"textmarshaled"`
	Error      string
}

Envelope represents a transaction, it is emitted by one emitter and is always started Open. Once the emitter sends the end_envelope event for this envelopeID it becomes closed.

func (Envelope) StructType 

func (Envelope) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type EnvelopeMapper 

type EnvelopeMapper struct{}

EnvelopeMapper is the Envelope mapper

func NewEnvelopeMapper 

func NewEnvelopeMapper() *EnvelopeMapper

NewEnvelopeMapper initialize a NewEnvelopeMapper

func (EnvelopeMapper) AutoIncrementPKey 

func (EnvelopeMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (EnvelopeMapper) FieldList 

func (mapper EnvelopeMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*EnvelopeMapper) GetMapper 

func (mapper *EnvelopeMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (EnvelopeMapper) LoadAutoIncrementPKeyValue 

func (EnvelopeMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*EnvelopeMapper) Name 

func (*EnvelopeMapper) Name() string

Name returns the mapper name

func (EnvelopeMapper) PKey 

func (mapper EnvelopeMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (EnvelopeMapper) PKeyClause 

func (mapper EnvelopeMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (EnvelopeMapper) SQLValues 

func (mapper EnvelopeMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (EnvelopeMapper) Scan 

func (mapper EnvelopeMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (EnvelopeMapper) ScanPKey 

func (mapper EnvelopeMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (EnvelopeMapper) StructType 

func (EnvelopeMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*EnvelopeMapper) Table 

func (*EnvelopeMapper) Table() *qb.TableElem

Table returns the mapper table

type EnvelopeModel 

type EnvelopeModel struct {
	TypesKnown yago.ScalarField
	EventIDs   yago.ScalarField
	Status     yago.MarshaledScalarField
	Error      yago.ScalarField
	ID         yago.ScalarField
	CreatedAt  yago.ScalarField
	UpdatedAt  yago.ScalarField
	// contains filtered or unexported fields
}

EnvelopeModel provides direct access to helpers for Envelope queries

func NewEnvelopeModel 

func NewEnvelopeModel(meta *yago.Metadata) EnvelopeModel

NewEnvelopeModel returns a new EnvelopeModel

func (EnvelopeModel) GetMapper 

func (m EnvelopeModel) GetMapper() yago.Mapper

GetMapper returns the associated EnvelopeMapper instance

type Event 

type Event struct {
	ID         int64     `yago:"primary_key,auto_increment"`
	EnvelopeID uuid.UUID `yago:"fk=Envelope ONDELETE CASCADE,unique_index=eventid"`
	EventID    uuid.UUID `yago:"unique_index=eventid"`
	EventType  string
	Status     storage.EnvelopeStorageReceptionStatus `yago:"textmarshaled"`
	ItemCount  uint64
	Checksum   api.Checksum `yago:"type=qb.Int().Unsigned()"`
	Validator  string
}

Event definitions

func (Event) StructType 

func (Event) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type EventMapper 

type EventMapper struct{}

EventMapper is the Event mapper

func NewEventMapper 

func NewEventMapper() *EventMapper

NewEventMapper initialize a NewEventMapper

func (EventMapper) AutoIncrementPKey 

func (EventMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (EventMapper) FieldList 

func (mapper EventMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*EventMapper) GetMapper 

func (mapper *EventMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (EventMapper) LoadAutoIncrementPKeyValue 

func (EventMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*EventMapper) Name 

func (*EventMapper) Name() string

Name returns the mapper name

func (EventMapper) PKey 

func (mapper EventMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (EventMapper) PKeyClause 

func (mapper EventMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (EventMapper) SQLValues 

func (mapper EventMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (EventMapper) Scan 

func (mapper EventMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (EventMapper) ScanPKey 

func (mapper EventMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (EventMapper) StructType 

func (EventMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*EventMapper) Table 

func (*EventMapper) Table() *qb.TableElem

Table returns the mapper table

type EventModel 

type EventModel struct {
	ID         yago.ScalarField
	EnvelopeID yago.ScalarField
	EventID    yago.ScalarField
	EventType  yago.ScalarField
	Status     yago.MarshaledScalarField
	ItemCount  yago.ScalarField
	Checksum   yago.ScalarField
	Validator  yago.ScalarField
	// contains filtered or unexported fields
}

EventModel provides direct access to helpers for Event queries

func NewEventModel 

func NewEventModel(meta *yago.Metadata) EventModel

NewEventModel returns a new EventModel

func (EventModel) GetMapper 

func (m EventModel) GetMapper() yago.Mapper

GetMapper returns the associated EventMapper instance

type GraphNode 

type GraphNode struct {
	ID                    int64     `yago:"auto_increment,primary_key"`
	PipelineID            uuid.UUID `yago:"fk=Pipeline,unique_index=graph_node"`
	NodeID                string    `yago:"unique_index=graph_node"`
	Type                  string
	ActorIDs              string
	Actors                string
	Roles                 string
	RoleBroadcast         bool
	SourceMatchEventTypes string
	Inputs                string `yago:"type=qb.Text()"`
	Outputs               string `yago:"type=qb.Text()"`
}

GraphNode is a graph vertex

func (GraphNode) StructType 

func (GraphNode) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type GraphNodeMapper 

type GraphNodeMapper struct{}

GraphNodeMapper is the GraphNode mapper

func NewGraphNodeMapper 

func NewGraphNodeMapper() *GraphNodeMapper

NewGraphNodeMapper initialize a NewGraphNodeMapper

func (GraphNodeMapper) AutoIncrementPKey 

func (GraphNodeMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (GraphNodeMapper) FieldList 

func (mapper GraphNodeMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*GraphNodeMapper) GetMapper 

func (mapper *GraphNodeMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (GraphNodeMapper) LoadAutoIncrementPKeyValue 

func (GraphNodeMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*GraphNodeMapper) Name 

func (*GraphNodeMapper) Name() string

Name returns the mapper name

func (GraphNodeMapper) PKey 

func (mapper GraphNodeMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (GraphNodeMapper) PKeyClause 

func (mapper GraphNodeMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (GraphNodeMapper) SQLValues 

func (mapper GraphNodeMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (GraphNodeMapper) Scan 

func (mapper GraphNodeMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (GraphNodeMapper) ScanPKey 

func (mapper GraphNodeMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (GraphNodeMapper) StructType 

func (GraphNodeMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*GraphNodeMapper) Table 

func (*GraphNodeMapper) Table() *qb.TableElem

Table returns the mapper table

type GraphNodeModel 

type GraphNodeModel struct {
	ID                    yago.ScalarField
	PipelineID            yago.ScalarField
	NodeID                yago.ScalarField
	Type                  yago.ScalarField
	ActorIDs              yago.ScalarField
	Actors                yago.ScalarField
	Roles                 yago.ScalarField
	RoleBroadcast         yago.ScalarField
	SourceMatchEventTypes yago.ScalarField
	Inputs                yago.ScalarField
	Outputs               yago.ScalarField
	// contains filtered or unexported fields
}

GraphNodeModel provides direct access to helpers for GraphNode queries

func NewGraphNodeModel 

func NewGraphNodeModel(meta *yago.Metadata) GraphNodeModel

NewGraphNodeModel returns a new GraphNodeModel

func (GraphNodeModel) GetMapper 

func (m GraphNodeModel) GetMapper() yago.Mapper

GetMapper returns the associated GraphNodeMapper instance

type Item 

type Item struct {
	ID      int64  `yago:"primary_key,auto_increment"`
	EventID int64  `yago:"fk=Event ONDELETE CASCADE,index=eventid_index_"`
	Batch   uint64 `yago:"."`
	Index   int64  `yago:"index_,index=eventid_index_"`
	Data    []byte `yago:"type=qb.Blob()"`
}

Item that can be stuffed into an event yago:

func (Item) StructType 

func (Item) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type ItemMapper 

type ItemMapper struct{}

ItemMapper is the Item mapper

func NewItemMapper 

func NewItemMapper() *ItemMapper

NewItemMapper initialize a NewItemMapper

func (ItemMapper) AutoIncrementPKey 

func (ItemMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (ItemMapper) FieldList 

func (mapper ItemMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*ItemMapper) GetMapper 

func (mapper *ItemMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (ItemMapper) LoadAutoIncrementPKeyValue 

func (ItemMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*ItemMapper) Name 

func (*ItemMapper) Name() string

Name returns the mapper name

func (ItemMapper) PKey 

func (mapper ItemMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (ItemMapper) PKeyClause 

func (mapper ItemMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (ItemMapper) SQLValues 

func (mapper ItemMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (ItemMapper) Scan 

func (mapper ItemMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (ItemMapper) ScanPKey 

func (mapper ItemMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (ItemMapper) StructType 

func (ItemMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*ItemMapper) Table 

func (*ItemMapper) Table() *qb.TableElem

Table returns the mapper table

type ItemModel 

type ItemModel struct {
	ID      yago.ScalarField
	EventID yago.ScalarField
	Batch   yago.ScalarField
	Index   yago.ScalarField
	Data    yago.ScalarField
	// contains filtered or unexported fields
}

ItemModel provides direct access to helpers for Item queries

func NewItemModel 

func NewItemModel(meta *yago.Metadata) ItemModel

NewItemModel returns a new ItemModel

func (ItemModel) GetMapper 

func (m ItemModel) GetMapper() yago.Mapper

GetMapper returns the associated ItemMapper instance

type LogEntry 

type LogEntry struct {
	ID         int64         `yago:"auto_increment,primary_key"`
	EnvelopeID uuid.NullUUID `yago:"fk=Envelope,index"`
	ActorID    uuid.NullUUID `yago:"fk=Actor,index"`
	ProcessID  uuid.NullUUID `yago:"index=processid_level"`
	NodeID     string
	Time       time.Time
	Level      api.LogLevel `yago:"type=qb.Varchar(),index=processid_level"`
	Text       string       `yago:"type=qb.Text()"`
}

LogEntry stores a api.LogEntry

func (LogEntry) StructType 

func (LogEntry) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type LogEntryMapper 

type LogEntryMapper struct{}

LogEntryMapper is the LogEntry mapper

func NewLogEntryMapper 

func NewLogEntryMapper() *LogEntryMapper

NewLogEntryMapper initialize a NewLogEntryMapper

func (LogEntryMapper) AutoIncrementPKey 

func (LogEntryMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (LogEntryMapper) FieldList 

func (mapper LogEntryMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*LogEntryMapper) GetMapper 

func (mapper *LogEntryMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (LogEntryMapper) LoadAutoIncrementPKeyValue 

func (LogEntryMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*LogEntryMapper) Name 

func (*LogEntryMapper) Name() string

Name returns the mapper name

func (LogEntryMapper) PKey 

func (mapper LogEntryMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (LogEntryMapper) PKeyClause 

func (mapper LogEntryMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (LogEntryMapper) SQLValues 

func (mapper LogEntryMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (LogEntryMapper) Scan 

func (mapper LogEntryMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (LogEntryMapper) ScanPKey 

func (mapper LogEntryMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (LogEntryMapper) StructType 

func (LogEntryMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*LogEntryMapper) Table 

func (*LogEntryMapper) Table() *qb.TableElem

Table returns the mapper table

type LogEntryModel 

type LogEntryModel struct {
	ID         yago.ScalarField
	EnvelopeID yago.ScalarField
	ActorID    yago.ScalarField
	ProcessID  yago.ScalarField
	NodeID     yago.ScalarField
	Time       yago.ScalarField
	Level      yago.ScalarField
	Text       yago.ScalarField
	// contains filtered or unexported fields
}

LogEntryModel provides direct access to helpers for LogEntry queries

func NewLogEntryModel 

func NewLogEntryModel(meta *yago.Metadata) LogEntryModel

NewLogEntryModel returns a new LogEntryModel

func (LogEntryModel) GetMapper 

func (m LogEntryModel) GetMapper() yago.Mapper

GetMapper returns the associated LogEntryMapper instance

type Model 

type Model struct {
	Meta *yago.Metadata

	Account         AccountModel
	Actor           ActorModel
	Envelope        EnvelopeModel
	Event           EventModel
	Item            ItemModel
	Process         ProcessModel
	ProcessLogEntry ProcessLogEntryModel
	ProcessState    ProcessStateModel
	Route           RouteModel
	RouteTarget     RouteTargetModel
	Pipeline        PipelineModel
	GraphNode       GraphNodeModel
	LogEntry        LogEntryModel
}

Model of the database

func NewDB 

func NewDB(driver string, params string, maxConns int, logger xbus.Logger, logFlags qb.LogFlags) (*Model, *yago.DB, error)

NewDB initialize a Model and a DB

func NewModel 

func NewModel() *Model

NewModel initialize a new Model

type NullTime 

type NullTime struct {
	Time  time.Time
	Valid bool // Valid is true if Time is not NULL
}

NullTime is a nullable time type that can be null this is a copy of https://github.com/lib/pq/blob/master/encode.go#L569

func (*NullTime) Scan 

func (nt *NullTime) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTime) Value 

func (nt NullTime) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Pipeline 

type Pipeline struct {
	Base
	Name    string                  `yago:"unique_index=name_version"`
	Version string                  `yago:"unique_index=name_version"`
	Status  api.PipelineInfo_Status `yago:"textmarshaled"`
	Edges   string                  `yago:"type=qb.Text()"`
}

Pipeline stores pipeline data

func (Pipeline) StructType 

func (Pipeline) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type PipelineMapper 

type PipelineMapper struct{}

PipelineMapper is the Pipeline mapper

func NewPipelineMapper 

func NewPipelineMapper() *PipelineMapper

NewPipelineMapper initialize a NewPipelineMapper

func (PipelineMapper) AutoIncrementPKey 

func (PipelineMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (PipelineMapper) FieldList 

func (mapper PipelineMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*PipelineMapper) GetMapper 

func (mapper *PipelineMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (PipelineMapper) LoadAutoIncrementPKeyValue 

func (PipelineMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*PipelineMapper) Name 

func (*PipelineMapper) Name() string

Name returns the mapper name

func (PipelineMapper) PKey 

func (mapper PipelineMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (PipelineMapper) PKeyClause 

func (mapper PipelineMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (PipelineMapper) SQLValues 

func (mapper PipelineMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (PipelineMapper) Scan 

func (mapper PipelineMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (PipelineMapper) ScanPKey 

func (mapper PipelineMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (PipelineMapper) StructType 

func (PipelineMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*PipelineMapper) Table 

func (*PipelineMapper) Table() *qb.TableElem

Table returns the mapper table

type PipelineModel 

type PipelineModel struct {
	Name      yago.ScalarField
	Version   yago.ScalarField
	Status    yago.MarshaledScalarField
	Edges     yago.ScalarField
	ID        yago.ScalarField
	CreatedAt yago.ScalarField
	UpdatedAt yago.ScalarField
	// contains filtered or unexported fields
}

PipelineModel provides direct access to helpers for Pipeline queries

func NewPipelineModel 

func NewPipelineModel(meta *yago.Metadata) PipelineModel

NewPipelineModel returns a new PipelineModel

func (PipelineModel) GetMapper 

func (m PipelineModel) GetMapper() yago.Mapper

GetMapper returns the associated PipelineMapper instance

type Process 

type Process struct {
	Base
	TriggerEmitterID  uuid.UUID `yago:"fk=Actor"`
	TriggerEnvelopeID uuid.UUID `yago:"fk=Envelope"`
	PipelineID        uuid.UUID `yago:"."`
	SourceNodeID      string    `yago:"."`
	SourceSlotID      string    `yago:"."`
}

Process stores process data yago:

func (Process) StructType 

func (Process) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type ProcessLogEntry 

type ProcessLogEntry struct {
	ID              int64     `yago:"primary_key,auto_increment"`
	Timestamp       time.Time `yago:"."`
	ProcessID       uuid.UUID `yago:"fk=Process ONDELETE CASCADE"`
	Data            string    `yago:"type=qb.Text()"`
	LogProcessed    bool      `yago:"."`
	ProcessingError bool      `yago:"."`
}

ProcessLogEntry stores storage.ProcessLogEntry yago:

func (ProcessLogEntry) StructType 

func (ProcessLogEntry) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type ProcessLogEntryMapper 

type ProcessLogEntryMapper struct{}

ProcessLogEntryMapper is the ProcessLogEntry mapper

func NewProcessLogEntryMapper 

func NewProcessLogEntryMapper() *ProcessLogEntryMapper

NewProcessLogEntryMapper initialize a NewProcessLogEntryMapper

func (ProcessLogEntryMapper) AutoIncrementPKey 

func (ProcessLogEntryMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (ProcessLogEntryMapper) FieldList 

func (mapper ProcessLogEntryMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*ProcessLogEntryMapper) GetMapper 

func (mapper *ProcessLogEntryMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (ProcessLogEntryMapper) LoadAutoIncrementPKeyValue 

func (ProcessLogEntryMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*ProcessLogEntryMapper) Name 

func (*ProcessLogEntryMapper) Name() string

Name returns the mapper name

func (ProcessLogEntryMapper) PKey 

func (mapper ProcessLogEntryMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (ProcessLogEntryMapper) PKeyClause 

func (mapper ProcessLogEntryMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (ProcessLogEntryMapper) SQLValues 

func (mapper ProcessLogEntryMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (ProcessLogEntryMapper) Scan 

func (mapper ProcessLogEntryMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (ProcessLogEntryMapper) ScanPKey 

func (mapper ProcessLogEntryMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (ProcessLogEntryMapper) StructType 

func (ProcessLogEntryMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*ProcessLogEntryMapper) Table 

func (*ProcessLogEntryMapper) Table() *qb.TableElem

Table returns the mapper table

type ProcessLogEntryModel 

type ProcessLogEntryModel struct {
	ID              yago.ScalarField
	Timestamp       yago.ScalarField
	ProcessID       yago.ScalarField
	Data            yago.ScalarField
	LogProcessed    yago.ScalarField
	ProcessingError yago.ScalarField
	// contains filtered or unexported fields
}

ProcessLogEntryModel provides direct access to helpers for ProcessLogEntry queries

func NewProcessLogEntryModel 

func NewProcessLogEntryModel(meta *yago.Metadata) ProcessLogEntryModel

NewProcessLogEntryModel returns a new ProcessLogEntryModel

func (ProcessLogEntryModel) GetMapper 

func (m ProcessLogEntryModel) GetMapper() yago.Mapper

GetMapper returns the associated ProcessLogEntryMapper instance

type ProcessMapper 

type ProcessMapper struct{}

ProcessMapper is the Process mapper

func NewProcessMapper 

func NewProcessMapper() *ProcessMapper

NewProcessMapper initialize a NewProcessMapper

func (ProcessMapper) AutoIncrementPKey 

func (ProcessMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (ProcessMapper) FieldList 

func (mapper ProcessMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*ProcessMapper) GetMapper 

func (mapper *ProcessMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (ProcessMapper) LoadAutoIncrementPKeyValue 

func (ProcessMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*ProcessMapper) Name 

func (*ProcessMapper) Name() string

Name returns the mapper name

func (ProcessMapper) PKey 

func (mapper ProcessMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (ProcessMapper) PKeyClause 

func (mapper ProcessMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (ProcessMapper) SQLValues 

func (mapper ProcessMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (ProcessMapper) Scan 

func (mapper ProcessMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (ProcessMapper) ScanPKey 

func (mapper ProcessMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (ProcessMapper) StructType 

func (ProcessMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*ProcessMapper) Table 

func (*ProcessMapper) Table() *qb.TableElem

Table returns the mapper table

type ProcessModel 

type ProcessModel struct {
	TriggerEmitterID  yago.ScalarField
	TriggerEnvelopeID yago.ScalarField
	PipelineID        yago.ScalarField
	SourceNodeID      yago.ScalarField
	SourceSlotID      yago.ScalarField
	ID                yago.ScalarField
	CreatedAt         yago.ScalarField
	UpdatedAt         yago.ScalarField
	// contains filtered or unexported fields
}

ProcessModel provides direct access to helpers for Process queries

func NewProcessModel 

func NewProcessModel(meta *yago.Metadata) ProcessModel

NewProcessModel returns a new ProcessModel

func (ProcessModel) GetMapper 

func (m ProcessModel) GetMapper() yago.Mapper

GetMapper returns the associated ProcessMapper instance

type ProcessState 

type ProcessState struct {
	ProcessID         uuid.UUID          `yago:"primary_key,fk=Process ONDELETE CASCADE"`
	Status            api.Process_Status `yago:"textmarshaled"`
	StatusChanged     time.Time
	StatusReason      string `yago:"type=qb.Text()"`
	NodeStates        string `yago:"type=qb.Text()"`
	NodeStatesChanged time.Time
	Response          uuid.NullUUID
	ResultAcked       bool
	PMLevel           api.LogLevel         `yago:"textmarshaled"`
	PMStatus          api.PMProcess_Status `yago:"textmarshaled"`
	PMComment         string
	PMChanged         time.Time
}

ProcessState stores a storage.ProcessState

func (ProcessState) StructType 

func (ProcessState) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type ProcessStateMapper 

type ProcessStateMapper struct{}

ProcessStateMapper is the ProcessState mapper

func NewProcessStateMapper 

func NewProcessStateMapper() *ProcessStateMapper

NewProcessStateMapper initialize a NewProcessStateMapper

func (ProcessStateMapper) AutoIncrementPKey 

func (ProcessStateMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (ProcessStateMapper) FieldList 

func (mapper ProcessStateMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*ProcessStateMapper) GetMapper 

func (mapper *ProcessStateMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (ProcessStateMapper) LoadAutoIncrementPKeyValue 

func (ProcessStateMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*ProcessStateMapper) Name 

func (*ProcessStateMapper) Name() string

Name returns the mapper name

func (ProcessStateMapper) PKey 

func (mapper ProcessStateMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (ProcessStateMapper) PKeyClause 

func (mapper ProcessStateMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (ProcessStateMapper) SQLValues 

func (mapper ProcessStateMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (ProcessStateMapper) Scan 

func (mapper ProcessStateMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (ProcessStateMapper) ScanPKey 

func (mapper ProcessStateMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (ProcessStateMapper) StructType 

func (ProcessStateMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*ProcessStateMapper) Table 

func (*ProcessStateMapper) Table() *qb.TableElem

Table returns the mapper table

type ProcessStateModel 

type ProcessStateModel struct {
	ProcessID         yago.ScalarField
	Status            yago.MarshaledScalarField
	StatusChanged     yago.ScalarField
	StatusReason      yago.ScalarField
	NodeStates        yago.ScalarField
	NodeStatesChanged yago.ScalarField
	Response          yago.ScalarField
	ResultAcked       yago.ScalarField
	PMLevel           yago.MarshaledScalarField
	PMStatus          yago.MarshaledScalarField
	PMComment         yago.ScalarField
	PMChanged         yago.ScalarField
	// contains filtered or unexported fields
}

ProcessStateModel provides direct access to helpers for ProcessState queries

func NewProcessStateModel 

func NewProcessStateModel(meta *yago.Metadata) ProcessStateModel

NewProcessStateModel returns a new ProcessStateModel

func (ProcessStateModel) GetMapper 

func (m ProcessStateModel) GetMapper() yago.Mapper

GetMapper returns the associated ProcessStateMapper instance

type QBLogger 

type QBLogger struct {
	// contains filtered or unexported fields
}

QBLogger implements qb.Logger on top of a xbus.Logger

func (QBLogger) Fatal 

func (l QBLogger) Fatal(v ...interface{})

Fatal is equivalent to xbus.Logger.Fatalf()

func (QBLogger) Fatalf 

func (l QBLogger) Fatalf(f string, v ...interface{})

Fatalf is equivalent to xbus.Logger.Fatalf()

func (QBLogger) Fatalln 

func (l QBLogger) Fatalln(v ...interface{})

Fatalln is equivalent to xbus.Logger.Fatalf()

func (QBLogger) LogFlags 

func (l QBLogger) LogFlags() qb.LogFlags

LogFlags returns the current log flags

func (QBLogger) Panic 

func (l QBLogger) Panic(v ...interface{})

Panic is equivalent to xbus.Logger.Errorf() + panic

func (QBLogger) Panicf 

func (l QBLogger) Panicf(f string, v ...interface{})

Panicf is equivalent to xbus.Logger.Errorf() + panic

func (QBLogger) Panicln 

func (l QBLogger) Panicln(v ...interface{})

Panicln is equivalent to xbus.Logger.Errorf() + panic

func (QBLogger) Print 

func (l QBLogger) Print(v ...interface{})

Print is equivalent to xbus.Logger.Noticef()

func (QBLogger) Printf 

func (l QBLogger) Printf(f string, v ...interface{})

Printf is equivalent to xbus.Logger.Noticef()

func (QBLogger) Println 

func (l QBLogger) Println(v ...interface{})

Println is equivalent to xbus.Logger.Noticef()

func (*QBLogger) SetLogFlags 

func (l *QBLogger) SetLogFlags(flags qb.LogFlags)

SetLogFlags changes the current log flags

type RawSQLBuilder 

type RawSQLBuilder struct {
	// contains filtered or unexported fields
}

RawSQLBuilder implements qb.Builder

func RawSQL 

func RawSQL(s string, bindings ...interface{}) RawSQLBuilder

RawSQL returns a RawSQLBuilder from a string and optionnaly bindings

func (RawSQLBuilder) Build 

func (b RawSQLBuilder) Build(dialect qb.Dialect) *qb.Stmt

Build creates a statement

type Route 

type Route struct {
	ID         int64     `yago:"primary_key,auto_increment"`
	ProcessID  uuid.UUID `yago:"fk=Process ONDELETE CASCADE,unique_index=route"`
	Source     string    `yago:"unique_index=route,type=qb.Text()"`
	EnvelopeID uuid.UUID `yago:"unique_index=route"`
}

Route stores routes associated to each node output in a Process yago:

func (Route) StructType 

func (Route) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type RouteMapper 

type RouteMapper struct{}

RouteMapper is the Route mapper

func NewRouteMapper 

func NewRouteMapper() *RouteMapper

NewRouteMapper initialize a NewRouteMapper

func (RouteMapper) AutoIncrementPKey 

func (RouteMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (RouteMapper) FieldList 

func (mapper RouteMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*RouteMapper) GetMapper 

func (mapper *RouteMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (RouteMapper) LoadAutoIncrementPKeyValue 

func (RouteMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*RouteMapper) Name 

func (*RouteMapper) Name() string

Name returns the mapper name

func (RouteMapper) PKey 

func (mapper RouteMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (RouteMapper) PKeyClause 

func (mapper RouteMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (RouteMapper) SQLValues 

func (mapper RouteMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (RouteMapper) Scan 

func (mapper RouteMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (RouteMapper) ScanPKey 

func (mapper RouteMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (RouteMapper) StructType 

func (RouteMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*RouteMapper) Table 

func (*RouteMapper) Table() *qb.TableElem

Table returns the mapper table

type RouteModel 

type RouteModel struct {
	ID         yago.ScalarField
	ProcessID  yago.ScalarField
	Source     yago.ScalarField
	EnvelopeID yago.ScalarField
	// contains filtered or unexported fields
}

RouteModel provides direct access to helpers for Route queries

func NewRouteModel 

func NewRouteModel(meta *yago.Metadata) RouteModel

NewRouteModel returns a new RouteModel

func (RouteModel) GetMapper 

func (m RouteModel) GetMapper() yago.Mapper

GetMapper returns the associated RouteMapper instance

type RouteTarget 

type RouteTarget struct {
	ID      int64     `yago:"primary_key,auto_increment"`
	RouteID int64     `yago:"fk=Route ONDELETE CASCADE,unique_index=target"`
	ActorID uuid.UUID `yago:"fk=Actor,unique_index=target"`
	NodeID  string    `yago:"unique_index=target"`
	Input   string    `yago:"unique_index=target"`
}

RouteTarget stores the targets of Route yago:

func (RouteTarget) StructType 

func (RouteTarget) StructType() reflect.Type

StructType returns the reflect.Type of the struct It is used for indexing mappers (and only that I guess, so it could be replaced with a unique identifier).

type RouteTargetMapper 

type RouteTargetMapper struct{}

RouteTargetMapper is the RouteTarget mapper

func NewRouteTargetMapper 

func NewRouteTargetMapper() *RouteTargetMapper

NewRouteTargetMapper initialize a NewRouteTargetMapper

func (RouteTargetMapper) AutoIncrementPKey 

func (RouteTargetMapper) AutoIncrementPKey() bool

AutoIncrementPKey return true if a column of the pkey is autoincremented

func (RouteTargetMapper) FieldList 

func (mapper RouteTargetMapper) FieldList() []qb.Clause

FieldList returns the list of fields for a select

func (*RouteTargetMapper) GetMapper 

func (mapper *RouteTargetMapper) GetMapper() yago.Mapper

GetMapper returns itself

func (RouteTargetMapper) LoadAutoIncrementPKeyValue 

func (RouteTargetMapper) LoadAutoIncrementPKeyValue(instance yago.MappedStruct, value int64)

LoadAutoIncrementPKeyValue set the pkey autoincremented column value

func (*RouteTargetMapper) Name 

func (*RouteTargetMapper) Name() string

Name returns the mapper name

func (RouteTargetMapper) PKey 

func (mapper RouteTargetMapper) PKey(instance yago.MappedStruct) (values []interface{})

PKey returns the instance primary key values

func (RouteTargetMapper) PKeyClause 

func (mapper RouteTargetMapper) PKeyClause(values []interface{}) qb.Clause

PKeyClause returns a clause that matches the instance primary key

func (RouteTargetMapper) SQLValues 

func (mapper RouteTargetMapper) SQLValues(instance yago.MappedStruct, fields ...string) map[string]interface{}

SQLValues returns values as a map The primary key is included only if having non-default values

func (RouteTargetMapper) Scan 

func (mapper RouteTargetMapper) Scan(rows *sql.Rows, instance yago.MappedStruct) error

Scan a struct

func (RouteTargetMapper) ScanPKey 

func (mapper RouteTargetMapper) ScanPKey(rows *sql.Rows, instance yago.MappedStruct) error

ScanPKey scans the primary key only

func (RouteTargetMapper) StructType 

func (RouteTargetMapper) StructType() reflect.Type

StructType returns the reflect.Type of the mapped structure

func (*RouteTargetMapper) Table 

func (*RouteTargetMapper) Table() *qb.TableElem

Table returns the mapper table

type RouteTargetModel 

type RouteTargetModel struct {
	ID      yago.ScalarField
	RouteID yago.ScalarField
	ActorID yago.ScalarField
	NodeID  yago.ScalarField
	Input   yago.ScalarField
	// contains filtered or unexported fields
}

RouteTargetModel provides direct access to helpers for RouteTarget queries

func NewRouteTargetModel 

func NewRouteTargetModel(meta *yago.Metadata) RouteTargetModel

NewRouteTargetModel returns a new RouteTargetModel

func (RouteTargetModel) GetMapper 

func (m RouteTargetModel) GetMapper() yago.Mapper

GetMapper returns the associated RouteTargetMapper instance

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.