model

package
Version: v0.0.0-...-821bb50 Latest Latest
Warning

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

Go to latest
Published: Jun 29, 2021 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 (
	// ProcessGroupID is the GroupID field name
	ProcessGroupID = "GroupID"
	// ProcessGroupIDColumnName is the GroupID field associated column name
	ProcessGroupIDColumnName = "group_id"
	// 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"
	// ProcessReplayOf is the ReplayOf field name
	ProcessReplayOf = "ReplayOf"
	// ProcessReplayOfColumnName is the ReplayOf field associated column name
	ProcessReplayOfColumnName = "replay_of"
	// 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 zerolog.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
	GroupID           uuid.NullUUID `yago:"fk=Process"`
	TriggerEmitterID  uuid.UUID     `yago:"fk=Actor"`
	TriggerEnvelopeID uuid.UUID     `yago:"fk=Envelope"`
	ReplayOf          uuid.NullUUID `yago:"fk=Process"`
	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

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 {
	GroupID           yago.ScalarField
	TriggerEmitterID  yago.ScalarField
	TriggerEnvelopeID yago.ScalarField
	ReplayOf          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 zerolog.Logger

func (QBLogger) Fatal

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

Fatal calls Fatal().Msg()

func (QBLogger) Fatalf

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

Fatalf calls Fatal().Msg()

func (QBLogger) Fatalln

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

Fatalln calls Fatal().Msg()

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 calls Panic().Msg()

func (QBLogger) Panicf

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

Panicf calls Panic().Msg()

func (QBLogger) Panicln

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

Panicln calls Panic().Msg()

func (QBLogger) Print

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

Print calls Debug().Msg()

func (QBLogger) Printf

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

Printf calls Debug().Msgf()

func (QBLogger) Println

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

Println calls Debug().Msg()

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL