ent

package

Go to main page

Versions in this module

v0

v0.5.1

Jul 5, 2026

v0.5.0

Mar 28, 2026

v0.4.0

Mar 23, 2026

Changes in this version

+ type AgentFilter struct

+ func (f *AgentFilter) Where(p entql.P)

+ func (f *AgentFilter) WhereChannelID(p entql.StringP)

+ func (f *AgentFilter) WhereConfig(p entql.BytesP)

+ func (f *AgentFilter) WhereID(p entql.StringP)

+ func (f *AgentFilter) WhereStatus(p entql.StringP)

+ func (f *AgentFilter) WhereTenantID(p entql.StringP)

+ func (f *AgentFilter) WhereType(p entql.StringP)

type AgentMutation

+ func (m *AgentMutation) Filter() *AgentFilter

type AgentQuery

+ func (_q *AgentQuery) Filter() *AgentFilter

+ type EventFilter struct

+ func (f *EventFilter) Where(p entql.P)

+ func (f *EventFilter) WhereAgentID(p entql.StringP)

+ func (f *EventFilter) WhereChannelID(p entql.StringP)

+ func (f *EventFilter) WhereID(p entql.StringP)

+ func (f *EventFilter) WherePayload(p entql.BytesP)

+ func (f *EventFilter) WhereRole(p entql.StringP)

+ func (f *EventFilter) WhereSourceAgentID(p entql.StringP)

+ func (f *EventFilter) WhereStatus(p entql.StringP)

+ func (f *EventFilter) WhereTenantID(p entql.StringP)

+ func (f *EventFilter) WhereTimestamp(p entql.TimeP)

+ func (f *EventFilter) WhereType(p entql.StringP)

type EventMutation

+ func (m *EventMutation) Filter() *EventFilter

type EventQuery

+ func (_q *EventQuery) Filter() *EventFilter

v0.3.0

Mar 16, 2026

Changes in this version

+ const OpCreate

+ const OpDelete

+ const OpDeleteOne

+ const OpUpdate

+ const OpUpdateOne

+ const TypeAgent

+ const TypeEvent

+ var ErrTxStarted = errors.New("ent: cannot start a transaction within a transaction")

+ func Asc(fields ...string) func(*sql.Selector)

+ func Desc(fields ...string) func(*sql.Selector)

+ func IsConstraintError(err error) bool

+ func IsNotFound(err error) bool

+ func IsNotLoaded(err error) bool

+ func IsNotSingular(err error) bool

+ func IsValidationError(err error) bool

+ func MaskNotFound(err error) error

+ func NewContext(parent context.Context, c *Client) context.Context

+ func NewTxContext(parent context.Context, tx *Tx) context.Context

+ type Agent struct

+ ChannelID string

+ Config map[string]interface{}

+ ID string

+ Status agent.Status

+ TenantID string

+ Type agent.Type

+ func (_m *Agent) String() string

+ func (_m *Agent) Unwrap() *Agent

+ func (_m *Agent) Update() *AgentUpdateOne

+ func (_m *Agent) Value(name string) (ent.Value, error)

+ type AgentClient struct

+ func NewAgentClient(c config) *AgentClient

+ func (c *AgentClient) Create() *AgentCreate

+ func (c *AgentClient) CreateBulk(builders ...*AgentCreate) *AgentCreateBulk

+ func (c *AgentClient) Delete() *AgentDelete

+ func (c *AgentClient) DeleteOne(_m *Agent) *AgentDeleteOne

+ func (c *AgentClient) DeleteOneID(id string) *AgentDeleteOne

+ func (c *AgentClient) Get(ctx context.Context, id string) (*Agent, error)

+ func (c *AgentClient) GetX(ctx context.Context, id string) *Agent

+ func (c *AgentClient) Hooks() []Hook

+ func (c *AgentClient) Intercept(interceptors ...Interceptor)

+ func (c *AgentClient) Interceptors() []Interceptor

+ func (c *AgentClient) MapCreateBulk(slice any, setFunc func(*AgentCreate, int)) *AgentCreateBulk

+ func (c *AgentClient) Query() *AgentQuery

+ func (c *AgentClient) Update() *AgentUpdate

+ func (c *AgentClient) UpdateOne(_m *Agent) *AgentUpdateOne

+ func (c *AgentClient) UpdateOneID(id string) *AgentUpdateOne

+ func (c *AgentClient) Use(hooks ...Hook)

+ type AgentCreate struct

+ func (_c *AgentCreate) Exec(ctx context.Context) error

+ func (_c *AgentCreate) ExecX(ctx context.Context)

+ func (_c *AgentCreate) Mutation() *AgentMutation

+ func (_c *AgentCreate) Save(ctx context.Context) (*Agent, error)

+ func (_c *AgentCreate) SaveX(ctx context.Context) *Agent

+ func (_c *AgentCreate) SetChannelID(v string) *AgentCreate

+ func (_c *AgentCreate) SetConfig(v map[string]interface{}) *AgentCreate

+ func (_c *AgentCreate) SetID(v string) *AgentCreate

+ func (_c *AgentCreate) SetNillableStatus(v *agent.Status) *AgentCreate

+ func (_c *AgentCreate) SetNillableTenantID(v *string) *AgentCreate

+ func (_c *AgentCreate) SetStatus(v agent.Status) *AgentCreate

+ func (_c *AgentCreate) SetTenantID(v string) *AgentCreate

+ func (_c *AgentCreate) SetType(v agent.Type) *AgentCreate

+ type AgentCreateBulk struct

+ func (_c *AgentCreateBulk) Exec(ctx context.Context) error

+ func (_c *AgentCreateBulk) ExecX(ctx context.Context)

+ func (_c *AgentCreateBulk) Save(ctx context.Context) ([]*Agent, error)

+ func (_c *AgentCreateBulk) SaveX(ctx context.Context) []*Agent

+ type AgentDelete struct

+ func (_d *AgentDelete) Exec(ctx context.Context) (int, error)

+ func (_d *AgentDelete) ExecX(ctx context.Context) int

+ func (_d *AgentDelete) Where(ps ...predicate.Agent) *AgentDelete

+ type AgentDeleteOne struct

+ func (_d *AgentDeleteOne) Exec(ctx context.Context) error

+ func (_d *AgentDeleteOne) ExecX(ctx context.Context)

+ func (_d *AgentDeleteOne) Where(ps ...predicate.Agent) *AgentDeleteOne

+ type AgentGroupBy struct

+ func (_g *AgentGroupBy) Aggregate(fns ...AggregateFunc) *AgentGroupBy

+ func (_g *AgentGroupBy) Scan(ctx context.Context, v any) error

+ func (s *AgentGroupBy) Bool(ctx context.Context) (_ bool, err error)

+ func (s *AgentGroupBy) BoolX(ctx context.Context) bool

+ func (s *AgentGroupBy) Bools(ctx context.Context) ([]bool, error)

+ func (s *AgentGroupBy) BoolsX(ctx context.Context) []bool

+ func (s *AgentGroupBy) Float64(ctx context.Context) (_ float64, err error)

+ func (s *AgentGroupBy) Float64X(ctx context.Context) float64

+ func (s *AgentGroupBy) Float64s(ctx context.Context) ([]float64, error)

+ func (s *AgentGroupBy) Float64sX(ctx context.Context) []float64

+ func (s *AgentGroupBy) Int(ctx context.Context) (_ int, err error)

+ func (s *AgentGroupBy) IntX(ctx context.Context) int

+ func (s *AgentGroupBy) Ints(ctx context.Context) ([]int, error)

+ func (s *AgentGroupBy) IntsX(ctx context.Context) []int

+ func (s *AgentGroupBy) ScanX(ctx context.Context, v any)

+ func (s *AgentGroupBy) String(ctx context.Context) (_ string, err error)

+ func (s *AgentGroupBy) StringX(ctx context.Context) string

+ func (s *AgentGroupBy) Strings(ctx context.Context) ([]string, error)

+ func (s *AgentGroupBy) StringsX(ctx context.Context) []string

+ type AgentMutation struct

+ func (m *AgentMutation) AddField(name string, value ent.Value) error

+ func (m *AgentMutation) AddedEdges() []string

+ func (m *AgentMutation) AddedField(name string) (ent.Value, bool)

+ func (m *AgentMutation) AddedFields() []string

+ func (m *AgentMutation) AddedIDs(name string) []ent.Value

+ func (m *AgentMutation) ChannelID() (r string, exists bool)

+ func (m *AgentMutation) ClearEdge(name string) error

+ func (m *AgentMutation) ClearField(name string) error

+ func (m *AgentMutation) ClearedEdges() []string

+ func (m *AgentMutation) ClearedFields() []string

+ func (m *AgentMutation) Config() (r map[string]interface{}, exists bool)

+ func (m *AgentMutation) EdgeCleared(name string) bool

+ func (m *AgentMutation) Field(name string) (ent.Value, bool)

+ func (m *AgentMutation) FieldCleared(name string) bool

+ func (m *AgentMutation) Fields() []string

+ func (m *AgentMutation) GetType() (r agent.Type, exists bool)

+ func (m *AgentMutation) ID() (id string, exists bool)

+ func (m *AgentMutation) IDs(ctx context.Context) ([]string, error)

+ func (m *AgentMutation) OldChannelID(ctx context.Context) (v string, err error)

+ func (m *AgentMutation) OldConfig(ctx context.Context) (v map[string]interface{}, err error)

+ func (m *AgentMutation) OldField(ctx context.Context, name string) (ent.Value, error)

+ func (m *AgentMutation) OldStatus(ctx context.Context) (v agent.Status, err error)

+ func (m *AgentMutation) OldTenantID(ctx context.Context) (v string, err error)

+ func (m *AgentMutation) OldType(ctx context.Context) (v agent.Type, err error)

+ func (m *AgentMutation) Op() Op

+ func (m *AgentMutation) RemovedEdges() []string

+ func (m *AgentMutation) RemovedIDs(name string) []ent.Value

+ func (m *AgentMutation) ResetChannelID()

+ func (m *AgentMutation) ResetConfig()

+ func (m *AgentMutation) ResetEdge(name string) error

+ func (m *AgentMutation) ResetField(name string) error

+ func (m *AgentMutation) ResetStatus()

+ func (m *AgentMutation) ResetTenantID()

+ func (m *AgentMutation) ResetType()

+ func (m *AgentMutation) SetChannelID(s string)

+ func (m *AgentMutation) SetConfig(value map[string]interface{})

+ func (m *AgentMutation) SetField(name string, value ent.Value) error

+ func (m *AgentMutation) SetID(id string)

+ func (m *AgentMutation) SetOp(op Op)

+ func (m *AgentMutation) SetStatus(a agent.Status)

+ func (m *AgentMutation) SetTenantID(s string)

+ func (m *AgentMutation) SetType(a agent.Type)

+ func (m *AgentMutation) Status() (r agent.Status, exists bool)

+ func (m *AgentMutation) TenantID() (r string, exists bool)

+ func (m *AgentMutation) Type() string

+ func (m *AgentMutation) Where(ps ...predicate.Agent)

+ func (m *AgentMutation) WhereP(ps ...func(*sql.Selector))

+ func (m AgentMutation) Client() *Client

+ func (m AgentMutation) Tx() (*Tx, error)

+ type AgentQuery struct

+ func (_q *AgentQuery) Aggregate(fns ...AggregateFunc) *AgentSelect

+ func (_q *AgentQuery) All(ctx context.Context) ([]*Agent, error)

+ func (_q *AgentQuery) AllX(ctx context.Context) []*Agent

+ func (_q *AgentQuery) Clone() *AgentQuery

+ func (_q *AgentQuery) Count(ctx context.Context) (int, error)

+ func (_q *AgentQuery) CountX(ctx context.Context) int

+ func (_q *AgentQuery) Exist(ctx context.Context) (bool, error)

+ func (_q *AgentQuery) ExistX(ctx context.Context) bool

+ func (_q *AgentQuery) First(ctx context.Context) (*Agent, error)

+ func (_q *AgentQuery) FirstID(ctx context.Context) (id string, err error)

+ func (_q *AgentQuery) FirstIDX(ctx context.Context) string

+ func (_q *AgentQuery) FirstX(ctx context.Context) *Agent

+ func (_q *AgentQuery) GroupBy(field string, fields ...string) *AgentGroupBy

+ func (_q *AgentQuery) IDs(ctx context.Context) (ids []string, err error)

+ func (_q *AgentQuery) IDsX(ctx context.Context) []string

+ func (_q *AgentQuery) Limit(limit int) *AgentQuery

+ func (_q *AgentQuery) Offset(offset int) *AgentQuery

+ func (_q *AgentQuery) Only(ctx context.Context) (*Agent, error)

+ func (_q *AgentQuery) OnlyID(ctx context.Context) (id string, err error)

+ func (_q *AgentQuery) OnlyIDX(ctx context.Context) string

+ func (_q *AgentQuery) OnlyX(ctx context.Context) *Agent

+ func (_q *AgentQuery) Order(o ...agent.OrderOption) *AgentQuery

+ func (_q *AgentQuery) Select(fields ...string) *AgentSelect

+ func (_q *AgentQuery) Unique(unique bool) *AgentQuery

+ func (_q *AgentQuery) Where(ps ...predicate.Agent) *AgentQuery

+ type AgentSelect struct

+ func (_s *AgentSelect) Aggregate(fns ...AggregateFunc) *AgentSelect

+ func (_s *AgentSelect) Scan(ctx context.Context, v any) error

+ func (s *AgentSelect) Bool(ctx context.Context) (_ bool, err error)

+ func (s *AgentSelect) BoolX(ctx context.Context) bool

+ func (s *AgentSelect) Bools(ctx context.Context) ([]bool, error)

+ func (s *AgentSelect) BoolsX(ctx context.Context) []bool

+ func (s *AgentSelect) Float64(ctx context.Context) (_ float64, err error)

+ func (s *AgentSelect) Float64X(ctx context.Context) float64

+ func (s *AgentSelect) Float64s(ctx context.Context) ([]float64, error)

+ func (s *AgentSelect) Float64sX(ctx context.Context) []float64

+ func (s *AgentSelect) Int(ctx context.Context) (_ int, err error)

+ func (s *AgentSelect) IntX(ctx context.Context) int

+ func (s *AgentSelect) Ints(ctx context.Context) ([]int, error)

+ func (s *AgentSelect) IntsX(ctx context.Context) []int

+ func (s *AgentSelect) ScanX(ctx context.Context, v any)

+ func (s *AgentSelect) String(ctx context.Context) (_ string, err error)

+ func (s *AgentSelect) StringX(ctx context.Context) string

+ func (s *AgentSelect) Strings(ctx context.Context) ([]string, error)

+ func (s *AgentSelect) StringsX(ctx context.Context) []string

+ type AgentUpdate struct

+ func (_u *AgentUpdate) Exec(ctx context.Context) error

+ func (_u *AgentUpdate) ExecX(ctx context.Context)

+ func (_u *AgentUpdate) Mutation() *AgentMutation

+ func (_u *AgentUpdate) Save(ctx context.Context) (int, error)

+ func (_u *AgentUpdate) SaveX(ctx context.Context) int

+ func (_u *AgentUpdate) SetChannelID(v string) *AgentUpdate

+ func (_u *AgentUpdate) SetConfig(v map[string]interface{}) *AgentUpdate

+ func (_u *AgentUpdate) SetNillableChannelID(v *string) *AgentUpdate

+ func (_u *AgentUpdate) SetNillableStatus(v *agent.Status) *AgentUpdate

+ func (_u *AgentUpdate) SetNillableTenantID(v *string) *AgentUpdate

+ func (_u *AgentUpdate) SetNillableType(v *agent.Type) *AgentUpdate

+ func (_u *AgentUpdate) SetStatus(v agent.Status) *AgentUpdate

+ func (_u *AgentUpdate) SetTenantID(v string) *AgentUpdate

+ func (_u *AgentUpdate) SetType(v agent.Type) *AgentUpdate

+ func (_u *AgentUpdate) Where(ps ...predicate.Agent) *AgentUpdate

+ type AgentUpdateOne struct

+ func (_u *AgentUpdateOne) Exec(ctx context.Context) error

+ func (_u *AgentUpdateOne) ExecX(ctx context.Context)

+ func (_u *AgentUpdateOne) Mutation() *AgentMutation

+ func (_u *AgentUpdateOne) Save(ctx context.Context) (*Agent, error)

+ func (_u *AgentUpdateOne) SaveX(ctx context.Context) *Agent

+ func (_u *AgentUpdateOne) Select(field string, fields ...string) *AgentUpdateOne

+ func (_u *AgentUpdateOne) SetChannelID(v string) *AgentUpdateOne

+ func (_u *AgentUpdateOne) SetConfig(v map[string]interface{}) *AgentUpdateOne

+ func (_u *AgentUpdateOne) SetNillableChannelID(v *string) *AgentUpdateOne

+ func (_u *AgentUpdateOne) SetNillableStatus(v *agent.Status) *AgentUpdateOne

+ func (_u *AgentUpdateOne) SetNillableTenantID(v *string) *AgentUpdateOne

+ func (_u *AgentUpdateOne) SetNillableType(v *agent.Type) *AgentUpdateOne

+ func (_u *AgentUpdateOne) SetStatus(v agent.Status) *AgentUpdateOne

+ func (_u *AgentUpdateOne) SetTenantID(v string) *AgentUpdateOne

+ func (_u *AgentUpdateOne) SetType(v agent.Type) *AgentUpdateOne

+ func (_u *AgentUpdateOne) Where(ps ...predicate.Agent) *AgentUpdateOne

+ type Agents []*Agent

+ type AggregateFunc func(*sql.Selector) string

+ func As(fn AggregateFunc, end string) AggregateFunc

+ func Count() AggregateFunc

+ func Max(field string) AggregateFunc

+ func Mean(field string) AggregateFunc

+ func Min(field string) AggregateFunc

+ func Sum(field string) AggregateFunc

+ type Client struct

+ Agent *AgentClient

+ Event *EventClient

+ Schema *migrate.Schema

+ func FromContext(ctx context.Context) *Client

+ func NewClient(opts ...Option) *Client

+ func Open(driverName, dataSourceName string, options ...Option) (*Client, error)

+ func (c *Client) BeginTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ func (c *Client) Close() error

+ func (c *Client) Debug() *Client

+ func (c *Client) Intercept(interceptors ...Interceptor)

+ func (c *Client) Mutate(ctx context.Context, m Mutation) (Value, error)

+ func (c *Client) Tx(ctx context.Context) (*Tx, error)

+ func (c *Client) Use(hooks ...Hook)

+ type CommitFunc func(context.Context, *Tx) error

+ func (f CommitFunc) Commit(ctx context.Context, tx *Tx) error

+ type CommitHook func(Committer) Committer

+ type Committer interface

+ Commit func(context.Context, *Tx) error

+ type ConstraintError struct

+ func (e *ConstraintError) Unwrap() error

+ func (e ConstraintError) Error() string

+ type Event struct

+ AgentID string

+ ChannelID string

+ ID string

+ Payload map[string]interface{}

+ Role event.Role

+ SourceAgentID string

+ Status event.Status

+ TenantID string

+ Timestamp time.Time

+ Type event.Type

+ func (_m *Event) String() string

+ func (_m *Event) Unwrap() *Event

+ func (_m *Event) Update() *EventUpdateOne

+ func (_m *Event) Value(name string) (ent.Value, error)

+ type EventClient struct

+ func NewEventClient(c config) *EventClient

+ func (c *EventClient) Create() *EventCreate

+ func (c *EventClient) CreateBulk(builders ...*EventCreate) *EventCreateBulk

+ func (c *EventClient) Delete() *EventDelete

+ func (c *EventClient) DeleteOne(_m *Event) *EventDeleteOne

+ func (c *EventClient) DeleteOneID(id string) *EventDeleteOne

+ func (c *EventClient) Get(ctx context.Context, id string) (*Event, error)

+ func (c *EventClient) GetX(ctx context.Context, id string) *Event

+ func (c *EventClient) Hooks() []Hook

+ func (c *EventClient) Intercept(interceptors ...Interceptor)

+ func (c *EventClient) Interceptors() []Interceptor

+ func (c *EventClient) MapCreateBulk(slice any, setFunc func(*EventCreate, int)) *EventCreateBulk

+ func (c *EventClient) Query() *EventQuery

+ func (c *EventClient) Update() *EventUpdate

+ func (c *EventClient) UpdateOne(_m *Event) *EventUpdateOne

+ func (c *EventClient) UpdateOneID(id string) *EventUpdateOne

+ func (c *EventClient) Use(hooks ...Hook)

+ type EventCreate struct

+ func (_c *EventCreate) Exec(ctx context.Context) error

+ func (_c *EventCreate) ExecX(ctx context.Context)

+ func (_c *EventCreate) Mutation() *EventMutation

+ func (_c *EventCreate) Save(ctx context.Context) (*Event, error)

+ func (_c *EventCreate) SaveX(ctx context.Context) *Event

+ func (_c *EventCreate) SetAgentID(v string) *EventCreate

+ func (_c *EventCreate) SetChannelID(v string) *EventCreate

+ func (_c *EventCreate) SetID(v string) *EventCreate

+ func (_c *EventCreate) SetNillableSourceAgentID(v *string) *EventCreate

+ func (_c *EventCreate) SetNillableStatus(v *event.Status) *EventCreate

+ func (_c *EventCreate) SetNillableTenantID(v *string) *EventCreate

+ func (_c *EventCreate) SetNillableTimestamp(v *time.Time) *EventCreate

+ func (_c *EventCreate) SetPayload(v map[string]interface{}) *EventCreate

+ func (_c *EventCreate) SetRole(v event.Role) *EventCreate

+ func (_c *EventCreate) SetSourceAgentID(v string) *EventCreate

+ func (_c *EventCreate) SetStatus(v event.Status) *EventCreate

+ func (_c *EventCreate) SetTenantID(v string) *EventCreate

+ func (_c *EventCreate) SetTimestamp(v time.Time) *EventCreate

+ func (_c *EventCreate) SetType(v event.Type) *EventCreate

+ type EventCreateBulk struct

+ func (_c *EventCreateBulk) Exec(ctx context.Context) error

+ func (_c *EventCreateBulk) ExecX(ctx context.Context)

+ func (_c *EventCreateBulk) Save(ctx context.Context) ([]*Event, error)

+ func (_c *EventCreateBulk) SaveX(ctx context.Context) []*Event

+ type EventDelete struct

+ func (_d *EventDelete) Exec(ctx context.Context) (int, error)

+ func (_d *EventDelete) ExecX(ctx context.Context) int

+ func (_d *EventDelete) Where(ps ...predicate.Event) *EventDelete

+ type EventDeleteOne struct

+ func (_d *EventDeleteOne) Exec(ctx context.Context) error

+ func (_d *EventDeleteOne) ExecX(ctx context.Context)

+ func (_d *EventDeleteOne) Where(ps ...predicate.Event) *EventDeleteOne

+ type EventGroupBy struct

+ func (_g *EventGroupBy) Aggregate(fns ...AggregateFunc) *EventGroupBy

+ func (_g *EventGroupBy) Scan(ctx context.Context, v any) error

+ func (s *EventGroupBy) Bool(ctx context.Context) (_ bool, err error)

+ func (s *EventGroupBy) BoolX(ctx context.Context) bool

+ func (s *EventGroupBy) Bools(ctx context.Context) ([]bool, error)

+ func (s *EventGroupBy) BoolsX(ctx context.Context) []bool

+ func (s *EventGroupBy) Float64(ctx context.Context) (_ float64, err error)

+ func (s *EventGroupBy) Float64X(ctx context.Context) float64

+ func (s *EventGroupBy) Float64s(ctx context.Context) ([]float64, error)

+ func (s *EventGroupBy) Float64sX(ctx context.Context) []float64

+ func (s *EventGroupBy) Int(ctx context.Context) (_ int, err error)

+ func (s *EventGroupBy) IntX(ctx context.Context) int

+ func (s *EventGroupBy) Ints(ctx context.Context) ([]int, error)

+ func (s *EventGroupBy) IntsX(ctx context.Context) []int

+ func (s *EventGroupBy) ScanX(ctx context.Context, v any)

+ func (s *EventGroupBy) String(ctx context.Context) (_ string, err error)

+ func (s *EventGroupBy) StringX(ctx context.Context) string

+ func (s *EventGroupBy) Strings(ctx context.Context) ([]string, error)

+ func (s *EventGroupBy) StringsX(ctx context.Context) []string

+ type EventMutation struct

+ func (m *EventMutation) AddField(name string, value ent.Value) error

+ func (m *EventMutation) AddedEdges() []string

+ func (m *EventMutation) AddedField(name string) (ent.Value, bool)

+ func (m *EventMutation) AddedFields() []string

+ func (m *EventMutation) AddedIDs(name string) []ent.Value

+ func (m *EventMutation) AgentID() (r string, exists bool)

+ func (m *EventMutation) ChannelID() (r string, exists bool)

+ func (m *EventMutation) ClearEdge(name string) error

+ func (m *EventMutation) ClearField(name string) error

+ func (m *EventMutation) ClearSourceAgentID()

+ func (m *EventMutation) ClearedEdges() []string

+ func (m *EventMutation) ClearedFields() []string

+ func (m *EventMutation) EdgeCleared(name string) bool

+ func (m *EventMutation) Field(name string) (ent.Value, bool)

+ func (m *EventMutation) FieldCleared(name string) bool

+ func (m *EventMutation) Fields() []string

+ func (m *EventMutation) GetType() (r event.Type, exists bool)

+ func (m *EventMutation) ID() (id string, exists bool)

+ func (m *EventMutation) IDs(ctx context.Context) ([]string, error)

+ func (m *EventMutation) OldAgentID(ctx context.Context) (v string, err error)

+ func (m *EventMutation) OldChannelID(ctx context.Context) (v string, err error)

+ func (m *EventMutation) OldField(ctx context.Context, name string) (ent.Value, error)

+ func (m *EventMutation) OldPayload(ctx context.Context) (v map[string]interface{}, err error)

+ func (m *EventMutation) OldRole(ctx context.Context) (v event.Role, err error)

+ func (m *EventMutation) OldSourceAgentID(ctx context.Context) (v string, err error)

+ func (m *EventMutation) OldStatus(ctx context.Context) (v event.Status, err error)

+ func (m *EventMutation) OldTenantID(ctx context.Context) (v string, err error)

+ func (m *EventMutation) OldTimestamp(ctx context.Context) (v time.Time, err error)

+ func (m *EventMutation) OldType(ctx context.Context) (v event.Type, err error)

+ func (m *EventMutation) Op() Op

+ func (m *EventMutation) Payload() (r map[string]interface{}, exists bool)

+ func (m *EventMutation) RemovedEdges() []string

+ func (m *EventMutation) RemovedIDs(name string) []ent.Value

+ func (m *EventMutation) ResetAgentID()

+ func (m *EventMutation) ResetChannelID()

+ func (m *EventMutation) ResetEdge(name string) error

+ func (m *EventMutation) ResetField(name string) error

+ func (m *EventMutation) ResetPayload()

+ func (m *EventMutation) ResetRole()

+ func (m *EventMutation) ResetSourceAgentID()

+ func (m *EventMutation) ResetStatus()

+ func (m *EventMutation) ResetTenantID()

+ func (m *EventMutation) ResetTimestamp()

+ func (m *EventMutation) ResetType()

+ func (m *EventMutation) Role() (r event.Role, exists bool)

+ func (m *EventMutation) SetAgentID(s string)

+ func (m *EventMutation) SetChannelID(s string)

+ func (m *EventMutation) SetField(name string, value ent.Value) error

+ func (m *EventMutation) SetID(id string)

+ func (m *EventMutation) SetOp(op Op)

+ func (m *EventMutation) SetPayload(value map[string]interface{})

+ func (m *EventMutation) SetRole(e event.Role)

+ func (m *EventMutation) SetSourceAgentID(s string)

+ func (m *EventMutation) SetStatus(e event.Status)

+ func (m *EventMutation) SetTenantID(s string)

+ func (m *EventMutation) SetTimestamp(t time.Time)

+ func (m *EventMutation) SetType(e event.Type)

+ func (m *EventMutation) SourceAgentID() (r string, exists bool)

+ func (m *EventMutation) SourceAgentIDCleared() bool

+ func (m *EventMutation) Status() (r event.Status, exists bool)

+ func (m *EventMutation) TenantID() (r string, exists bool)

+ func (m *EventMutation) Timestamp() (r time.Time, exists bool)

+ func (m *EventMutation) Type() string

+ func (m *EventMutation) Where(ps ...predicate.Event)

+ func (m *EventMutation) WhereP(ps ...func(*sql.Selector))

+ func (m EventMutation) Client() *Client

+ func (m EventMutation) Tx() (*Tx, error)

+ type EventQuery struct

+ func (_q *EventQuery) Aggregate(fns ...AggregateFunc) *EventSelect

+ func (_q *EventQuery) All(ctx context.Context) ([]*Event, error)

+ func (_q *EventQuery) AllX(ctx context.Context) []*Event

+ func (_q *EventQuery) Clone() *EventQuery

+ func (_q *EventQuery) Count(ctx context.Context) (int, error)

+ func (_q *EventQuery) CountX(ctx context.Context) int

+ func (_q *EventQuery) Exist(ctx context.Context) (bool, error)

+ func (_q *EventQuery) ExistX(ctx context.Context) bool

+ func (_q *EventQuery) First(ctx context.Context) (*Event, error)

+ func (_q *EventQuery) FirstID(ctx context.Context) (id string, err error)

+ func (_q *EventQuery) FirstIDX(ctx context.Context) string

+ func (_q *EventQuery) FirstX(ctx context.Context) *Event

+ func (_q *EventQuery) GroupBy(field string, fields ...string) *EventGroupBy

+ func (_q *EventQuery) IDs(ctx context.Context) (ids []string, err error)

+ func (_q *EventQuery) IDsX(ctx context.Context) []string

+ func (_q *EventQuery) Limit(limit int) *EventQuery

+ func (_q *EventQuery) Offset(offset int) *EventQuery

+ func (_q *EventQuery) Only(ctx context.Context) (*Event, error)

+ func (_q *EventQuery) OnlyID(ctx context.Context) (id string, err error)

+ func (_q *EventQuery) OnlyIDX(ctx context.Context) string

+ func (_q *EventQuery) OnlyX(ctx context.Context) *Event

+ func (_q *EventQuery) Order(o ...event.OrderOption) *EventQuery

+ func (_q *EventQuery) Select(fields ...string) *EventSelect

+ func (_q *EventQuery) Unique(unique bool) *EventQuery

+ func (_q *EventQuery) Where(ps ...predicate.Event) *EventQuery

+ type EventSelect struct

+ func (_s *EventSelect) Aggregate(fns ...AggregateFunc) *EventSelect

+ func (_s *EventSelect) Scan(ctx context.Context, v any) error

+ func (s *EventSelect) Bool(ctx context.Context) (_ bool, err error)

+ func (s *EventSelect) BoolX(ctx context.Context) bool

+ func (s *EventSelect) Bools(ctx context.Context) ([]bool, error)

+ func (s *EventSelect) BoolsX(ctx context.Context) []bool

+ func (s *EventSelect) Float64(ctx context.Context) (_ float64, err error)

+ func (s *EventSelect) Float64X(ctx context.Context) float64

+ func (s *EventSelect) Float64s(ctx context.Context) ([]float64, error)

+ func (s *EventSelect) Float64sX(ctx context.Context) []float64

+ func (s *EventSelect) Int(ctx context.Context) (_ int, err error)

+ func (s *EventSelect) IntX(ctx context.Context) int

+ func (s *EventSelect) Ints(ctx context.Context) ([]int, error)

+ func (s *EventSelect) IntsX(ctx context.Context) []int

+ func (s *EventSelect) ScanX(ctx context.Context, v any)

+ func (s *EventSelect) String(ctx context.Context) (_ string, err error)

+ func (s *EventSelect) StringX(ctx context.Context) string

+ func (s *EventSelect) Strings(ctx context.Context) ([]string, error)

+ func (s *EventSelect) StringsX(ctx context.Context) []string

+ type EventUpdate struct

+ func (_u *EventUpdate) ClearSourceAgentID() *EventUpdate

+ func (_u *EventUpdate) Exec(ctx context.Context) error

+ func (_u *EventUpdate) ExecX(ctx context.Context)

+ func (_u *EventUpdate) Mutation() *EventMutation

+ func (_u *EventUpdate) Save(ctx context.Context) (int, error)

+ func (_u *EventUpdate) SaveX(ctx context.Context) int

+ func (_u *EventUpdate) SetAgentID(v string) *EventUpdate

+ func (_u *EventUpdate) SetChannelID(v string) *EventUpdate

+ func (_u *EventUpdate) SetNillableAgentID(v *string) *EventUpdate

+ func (_u *EventUpdate) SetNillableChannelID(v *string) *EventUpdate

+ func (_u *EventUpdate) SetNillableRole(v *event.Role) *EventUpdate

+ func (_u *EventUpdate) SetNillableSourceAgentID(v *string) *EventUpdate

+ func (_u *EventUpdate) SetNillableStatus(v *event.Status) *EventUpdate

+ func (_u *EventUpdate) SetNillableTenantID(v *string) *EventUpdate

+ func (_u *EventUpdate) SetNillableTimestamp(v *time.Time) *EventUpdate

+ func (_u *EventUpdate) SetNillableType(v *event.Type) *EventUpdate

+ func (_u *EventUpdate) SetPayload(v map[string]interface{}) *EventUpdate

+ func (_u *EventUpdate) SetRole(v event.Role) *EventUpdate

+ func (_u *EventUpdate) SetSourceAgentID(v string) *EventUpdate

+ func (_u *EventUpdate) SetStatus(v event.Status) *EventUpdate

+ func (_u *EventUpdate) SetTenantID(v string) *EventUpdate

+ func (_u *EventUpdate) SetTimestamp(v time.Time) *EventUpdate

+ func (_u *EventUpdate) SetType(v event.Type) *EventUpdate

+ func (_u *EventUpdate) Where(ps ...predicate.Event) *EventUpdate

+ type EventUpdateOne struct

+ func (_u *EventUpdateOne) ClearSourceAgentID() *EventUpdateOne

+ func (_u *EventUpdateOne) Exec(ctx context.Context) error

+ func (_u *EventUpdateOne) ExecX(ctx context.Context)

+ func (_u *EventUpdateOne) Mutation() *EventMutation

+ func (_u *EventUpdateOne) Save(ctx context.Context) (*Event, error)

+ func (_u *EventUpdateOne) SaveX(ctx context.Context) *Event

+ func (_u *EventUpdateOne) Select(field string, fields ...string) *EventUpdateOne

+ func (_u *EventUpdateOne) SetAgentID(v string) *EventUpdateOne

+ func (_u *EventUpdateOne) SetChannelID(v string) *EventUpdateOne

+ func (_u *EventUpdateOne) SetNillableAgentID(v *string) *EventUpdateOne

+ func (_u *EventUpdateOne) SetNillableChannelID(v *string) *EventUpdateOne

+ func (_u *EventUpdateOne) SetNillableRole(v *event.Role) *EventUpdateOne

+ func (_u *EventUpdateOne) SetNillableSourceAgentID(v *string) *EventUpdateOne

+ func (_u *EventUpdateOne) SetNillableStatus(v *event.Status) *EventUpdateOne

+ func (_u *EventUpdateOne) SetNillableTenantID(v *string) *EventUpdateOne

+ func (_u *EventUpdateOne) SetNillableTimestamp(v *time.Time) *EventUpdateOne

+ func (_u *EventUpdateOne) SetNillableType(v *event.Type) *EventUpdateOne

+ func (_u *EventUpdateOne) SetPayload(v map[string]interface{}) *EventUpdateOne

+ func (_u *EventUpdateOne) SetRole(v event.Role) *EventUpdateOne

+ func (_u *EventUpdateOne) SetSourceAgentID(v string) *EventUpdateOne

+ func (_u *EventUpdateOne) SetStatus(v event.Status) *EventUpdateOne

+ func (_u *EventUpdateOne) SetTenantID(v string) *EventUpdateOne

+ func (_u *EventUpdateOne) SetTimestamp(v time.Time) *EventUpdateOne

+ func (_u *EventUpdateOne) SetType(v event.Type) *EventUpdateOne

+ func (_u *EventUpdateOne) Where(ps ...predicate.Event) *EventUpdateOne

+ type Events []*Event

+ type Hook = ent.Hook

+ type InterceptFunc = ent.InterceptFunc

+ type Interceptor = ent.Interceptor

+ type MutateFunc = ent.MutateFunc

+ type Mutation = ent.Mutation

+ type Mutator = ent.Mutator

+ type NotFoundError struct

+ func (e *NotFoundError) Error() string

+ type NotLoadedError struct

+ func (e *NotLoadedError) Error() string

+ type NotSingularError struct

+ func (e *NotSingularError) Error() string

+ type Op = ent.Op

+ type Option func(*config)

+ func Debug() Option

+ func Driver(driver dialect.Driver) Option

+ func Log(fn func(...any)) Option

+ type OrderFunc func(*sql.Selector)

+ type Policy = ent.Policy

+ type Querier = ent.Querier

+ type QuerierFunc = ent.QuerierFunc

+ type Query = ent.Query

+ type QueryContext = ent.QueryContext

+ type RollbackFunc func(context.Context, *Tx) error

+ func (f RollbackFunc) Rollback(ctx context.Context, tx *Tx) error

+ type RollbackHook func(Rollbacker) Rollbacker

+ type Rollbacker interface

+ Rollback func(context.Context, *Tx) error

+ type TraverseFunc = ent.TraverseFunc

+ type Traverser = ent.Traverser

+ type Tx struct

+ Agent *AgentClient

+ Event *EventClient

+ func TxFromContext(ctx context.Context) *Tx

+ func (tx *Tx) Client() *Client

+ func (tx *Tx) Commit() error

+ func (tx *Tx) OnCommit(f CommitHook)

+ func (tx *Tx) OnRollback(f RollbackHook)

+ func (tx *Tx) Rollback() error

+ type ValidationError struct

+ Name string

+ func (e *ValidationError) Error() string

+ func (e *ValidationError) Unwrap() error

+ type Value = ent.Value

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL