ent

package

Go to main page

Versions in this module

v0

v0.2.0

Jun 6, 2023

Changes in this version

type Chunk

+ func (c *Chunk) Value(name string) (ent.Value, error)

type ChunkClient

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

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

type ChunkCreate

+ func (cc *ChunkCreate) OnConflict(opts ...sql.ConflictOption) *ChunkUpsertOne

+ func (cc *ChunkCreate) OnConflictColumns(columns ...string) *ChunkUpsertOne

type ChunkCreateBulk

+ func (ccb *ChunkCreateBulk) OnConflict(opts ...sql.ConflictOption) *ChunkUpsertBulk

+ func (ccb *ChunkCreateBulk) OnConflictColumns(columns ...string) *ChunkUpsertBulk

type ChunkDeleteOne

+ func (cdo *ChunkDeleteOne) Where(ps ...predicate.Chunk) *ChunkDeleteOne

type ChunkMutation

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

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

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

type ChunkQuery

+ func (cq *ChunkQuery) Aggregate(fns ...AggregateFunc) *ChunkSelect

type ChunkSelect

+ func (cs *ChunkSelect) Aggregate(fns ...AggregateFunc) *ChunkSelect

type ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) Where(ps ...predicate.Chunk) *ChunkUpdateOne

+ type ChunkUpsert struct

+ func (u *ChunkUpsert) AddSizeContent(v int64) *ChunkUpsert

+ func (u *ChunkUpsert) AddSizeInput(v int64) *ChunkUpsert

+ func (u *ChunkUpsert) AddSizeOutput(v int64) *ChunkUpsert

+ func (u *ChunkUpsert) ClearLeaseExpiresAt() *ChunkUpsert

+ func (u *ChunkUpsert) ClearSha256Content() *ChunkUpsert

+ func (u *ChunkUpsert) ClearSha256Input() *ChunkUpsert

+ func (u *ChunkUpsert) ClearSha256Output() *ChunkUpsert

+ func (u *ChunkUpsert) ClearSizeContent() *ChunkUpsert

+ func (u *ChunkUpsert) ClearSizeInput() *ChunkUpsert

+ func (u *ChunkUpsert) ClearSizeOutput() *ChunkUpsert

+ func (u *ChunkUpsert) SetLeaseExpiresAt(v time.Time) *ChunkUpsert

+ func (u *ChunkUpsert) SetSha256Content(v string) *ChunkUpsert

+ func (u *ChunkUpsert) SetSha256Input(v string) *ChunkUpsert

+ func (u *ChunkUpsert) SetSha256Output(v string) *ChunkUpsert

+ func (u *ChunkUpsert) SetSizeContent(v int64) *ChunkUpsert

+ func (u *ChunkUpsert) SetSizeInput(v int64) *ChunkUpsert

+ func (u *ChunkUpsert) SetSizeOutput(v int64) *ChunkUpsert

+ func (u *ChunkUpsert) SetStart(v time.Time) *ChunkUpsert

+ func (u *ChunkUpsert) SetState(v chunk.State) *ChunkUpsert

+ func (u *ChunkUpsert) SetUpdatedAt(v time.Time) *ChunkUpsert

+ func (u *ChunkUpsert) UpdateLeaseExpiresAt() *ChunkUpsert

+ func (u *ChunkUpsert) UpdateSha256Content() *ChunkUpsert

+ func (u *ChunkUpsert) UpdateSha256Input() *ChunkUpsert

+ func (u *ChunkUpsert) UpdateSha256Output() *ChunkUpsert

+ func (u *ChunkUpsert) UpdateSizeContent() *ChunkUpsert

+ func (u *ChunkUpsert) UpdateSizeInput() *ChunkUpsert

+ func (u *ChunkUpsert) UpdateSizeOutput() *ChunkUpsert

+ func (u *ChunkUpsert) UpdateStart() *ChunkUpsert

+ func (u *ChunkUpsert) UpdateState() *ChunkUpsert

+ func (u *ChunkUpsert) UpdateUpdatedAt() *ChunkUpsert

+ type ChunkUpsertBulk struct

+ func (u *ChunkUpsertBulk) AddSizeContent(v int64) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) AddSizeInput(v int64) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) AddSizeOutput(v int64) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) ClearLeaseExpiresAt() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) ClearSha256Content() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) ClearSha256Input() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) ClearSha256Output() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) ClearSizeContent() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) ClearSizeInput() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) ClearSizeOutput() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) DoNothing() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) Exec(ctx context.Context) error

+ func (u *ChunkUpsertBulk) ExecX(ctx context.Context)

+ func (u *ChunkUpsertBulk) Ignore() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) SetLeaseExpiresAt(v time.Time) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) SetSha256Content(v string) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) SetSha256Input(v string) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) SetSha256Output(v string) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) SetSizeContent(v int64) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) SetSizeInput(v int64) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) SetSizeOutput(v int64) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) SetStart(v time.Time) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) SetState(v chunk.State) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) SetUpdatedAt(v time.Time) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) Update(set func(*ChunkUpsert)) *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateLeaseExpiresAt() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateNewValues() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateSha256Content() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateSha256Input() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateSha256Output() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateSizeContent() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateSizeInput() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateSizeOutput() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateStart() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateState() *ChunkUpsertBulk

+ func (u *ChunkUpsertBulk) UpdateUpdatedAt() *ChunkUpsertBulk

+ type ChunkUpsertOne struct

+ func (u *ChunkUpsertOne) AddSizeContent(v int64) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) AddSizeInput(v int64) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) AddSizeOutput(v int64) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) ClearLeaseExpiresAt() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) ClearSha256Content() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) ClearSha256Input() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) ClearSha256Output() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) ClearSizeContent() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) ClearSizeInput() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) ClearSizeOutput() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) DoNothing() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) Exec(ctx context.Context) error

+ func (u *ChunkUpsertOne) ExecX(ctx context.Context)

+ func (u *ChunkUpsertOne) ID(ctx context.Context) (id string, err error)

+ func (u *ChunkUpsertOne) IDX(ctx context.Context) string

+ func (u *ChunkUpsertOne) Ignore() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) SetLeaseExpiresAt(v time.Time) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) SetSha256Content(v string) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) SetSha256Input(v string) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) SetSha256Output(v string) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) SetSizeContent(v int64) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) SetSizeInput(v int64) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) SetSizeOutput(v int64) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) SetStart(v time.Time) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) SetState(v chunk.State) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) SetUpdatedAt(v time.Time) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) Update(set func(*ChunkUpsert)) *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateLeaseExpiresAt() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateNewValues() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateSha256Content() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateSha256Input() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateSha256Output() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateSizeContent() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateSizeInput() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateSizeOutput() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateStart() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateState() *ChunkUpsertOne

+ func (u *ChunkUpsertOne) UpdateUpdatedAt() *ChunkUpsertOne

type Client

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

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

+ type InterceptFunc = ent.InterceptFunc

+ type Interceptor = ent.Interceptor

+ type Querier = ent.Querier

+ type QuerierFunc = ent.QuerierFunc

+ type QueryContext = ent.QueryContext

+ type TraverseFunc = ent.TraverseFunc

+ type Traverser = ent.Traverser

type Worker

+ func (w *Worker) Value(name string) (ent.Value, error)

type WorkerClient

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

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

type WorkerCreate

+ func (wc *WorkerCreate) OnConflict(opts ...sql.ConflictOption) *WorkerUpsertOne

+ func (wc *WorkerCreate) OnConflictColumns(columns ...string) *WorkerUpsertOne

+ func (wc *WorkerCreate) SetNillableID(u *uuid.UUID) *WorkerCreate

type WorkerCreateBulk

+ func (wcb *WorkerCreateBulk) OnConflict(opts ...sql.ConflictOption) *WorkerUpsertBulk

+ func (wcb *WorkerCreateBulk) OnConflictColumns(columns ...string) *WorkerUpsertBulk

type WorkerDeleteOne

+ func (wdo *WorkerDeleteOne) Where(ps ...predicate.Worker) *WorkerDeleteOne

type WorkerMutation

+ func (m *WorkerMutation) IDs(ctx context.Context) ([]uuid.UUID, error)

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

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

type WorkerQuery

+ func (wq *WorkerQuery) Aggregate(fns ...AggregateFunc) *WorkerSelect

type WorkerSelect

+ func (ws *WorkerSelect) Aggregate(fns ...AggregateFunc) *WorkerSelect

type WorkerUpdateOne

+ func (wuo *WorkerUpdateOne) Where(ps ...predicate.Worker) *WorkerUpdateOne

+ type WorkerUpsert struct

+ func (u *WorkerUpsert) SetName(v string) *WorkerUpsert

+ func (u *WorkerUpsert) SetToken(v string) *WorkerUpsert

+ func (u *WorkerUpsert) SetUpdatedAt(v time.Time) *WorkerUpsert

+ func (u *WorkerUpsert) UpdateName() *WorkerUpsert

+ func (u *WorkerUpsert) UpdateToken() *WorkerUpsert

+ func (u *WorkerUpsert) UpdateUpdatedAt() *WorkerUpsert

+ type WorkerUpsertBulk struct

+ func (u *WorkerUpsertBulk) DoNothing() *WorkerUpsertBulk

+ func (u *WorkerUpsertBulk) Exec(ctx context.Context) error

+ func (u *WorkerUpsertBulk) ExecX(ctx context.Context)

+ func (u *WorkerUpsertBulk) Ignore() *WorkerUpsertBulk

+ func (u *WorkerUpsertBulk) SetName(v string) *WorkerUpsertBulk

+ func (u *WorkerUpsertBulk) SetToken(v string) *WorkerUpsertBulk

+ func (u *WorkerUpsertBulk) SetUpdatedAt(v time.Time) *WorkerUpsertBulk

+ func (u *WorkerUpsertBulk) Update(set func(*WorkerUpsert)) *WorkerUpsertBulk

+ func (u *WorkerUpsertBulk) UpdateName() *WorkerUpsertBulk

+ func (u *WorkerUpsertBulk) UpdateNewValues() *WorkerUpsertBulk

+ func (u *WorkerUpsertBulk) UpdateToken() *WorkerUpsertBulk

+ func (u *WorkerUpsertBulk) UpdateUpdatedAt() *WorkerUpsertBulk

+ type WorkerUpsertOne struct

+ func (u *WorkerUpsertOne) DoNothing() *WorkerUpsertOne

+ func (u *WorkerUpsertOne) Exec(ctx context.Context) error

+ func (u *WorkerUpsertOne) ExecX(ctx context.Context)

+ func (u *WorkerUpsertOne) ID(ctx context.Context) (id uuid.UUID, err error)

+ func (u *WorkerUpsertOne) IDX(ctx context.Context) uuid.UUID

+ func (u *WorkerUpsertOne) Ignore() *WorkerUpsertOne

+ func (u *WorkerUpsertOne) SetName(v string) *WorkerUpsertOne

+ func (u *WorkerUpsertOne) SetToken(v string) *WorkerUpsertOne

+ func (u *WorkerUpsertOne) SetUpdatedAt(v time.Time) *WorkerUpsertOne

+ func (u *WorkerUpsertOne) Update(set func(*WorkerUpsert)) *WorkerUpsertOne

+ func (u *WorkerUpsertOne) UpdateName() *WorkerUpsertOne

+ func (u *WorkerUpsertOne) UpdateNewValues() *WorkerUpsertOne

+ func (u *WorkerUpsertOne) UpdateToken() *WorkerUpsertOne

+ func (u *WorkerUpsertOne) UpdateUpdatedAt() *WorkerUpsertOne

v0.1.0

Nov 25, 2021

Changes in this version

+ const OpCreate

+ const OpDelete

+ const OpDeleteOne

+ const OpUpdate

+ const OpUpdateOne

+ const TypeChunk

+ const TypeWorker

+ 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 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 Chunk struct

+ CreatedAt time.Time

+ Edges ChunkEdges

+ ID string

+ LeaseExpiresAt time.Time

+ Sha256Content *string

+ Sha256Input *string

+ Sha256Output *string

+ SizeContent int64

+ SizeInput int64

+ SizeOutput int64

+ Start time.Time

+ State chunk.State

+ UpdatedAt time.Time

+ func (c *Chunk) QueryWorker() *WorkerQuery

+ func (c *Chunk) String() string

+ func (c *Chunk) Unwrap() *Chunk

+ func (c *Chunk) Update() *ChunkUpdateOne

+ type ChunkClient struct

+ func NewChunkClient(c config) *ChunkClient

+ func (c *ChunkClient) Create() *ChunkCreate

+ func (c *ChunkClient) CreateBulk(builders ...*ChunkCreate) *ChunkCreateBulk

+ func (c *ChunkClient) Delete() *ChunkDelete

+ func (c *ChunkClient) DeleteOne(ch *Chunk) *ChunkDeleteOne

+ func (c *ChunkClient) DeleteOneID(id string) *ChunkDeleteOne

+ func (c *ChunkClient) Get(ctx context.Context, id string) (*Chunk, error)

+ func (c *ChunkClient) GetX(ctx context.Context, id string) *Chunk

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

+ func (c *ChunkClient) Query() *ChunkQuery

+ func (c *ChunkClient) QueryWorker(ch *Chunk) *WorkerQuery

+ func (c *ChunkClient) Update() *ChunkUpdate

+ func (c *ChunkClient) UpdateOne(ch *Chunk) *ChunkUpdateOne

+ func (c *ChunkClient) UpdateOneID(id string) *ChunkUpdateOne

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

+ type ChunkCreate struct

+ func (cc *ChunkCreate) Exec(ctx context.Context) error

+ func (cc *ChunkCreate) ExecX(ctx context.Context)

+ func (cc *ChunkCreate) Mutation() *ChunkMutation

+ func (cc *ChunkCreate) Save(ctx context.Context) (*Chunk, error)

+ func (cc *ChunkCreate) SaveX(ctx context.Context) *Chunk

+ func (cc *ChunkCreate) SetCreatedAt(t time.Time) *ChunkCreate

+ func (cc *ChunkCreate) SetID(s string) *ChunkCreate

+ func (cc *ChunkCreate) SetLeaseExpiresAt(t time.Time) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableCreatedAt(t *time.Time) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableLeaseExpiresAt(t *time.Time) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableSha256Content(s *string) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableSha256Input(s *string) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableSha256Output(s *string) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableSizeContent(i *int64) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableSizeInput(i *int64) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableSizeOutput(i *int64) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableState(c *chunk.State) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableUpdatedAt(t *time.Time) *ChunkCreate

+ func (cc *ChunkCreate) SetNillableWorkerID(id *uuid.UUID) *ChunkCreate

+ func (cc *ChunkCreate) SetSha256Content(s string) *ChunkCreate

+ func (cc *ChunkCreate) SetSha256Input(s string) *ChunkCreate

+ func (cc *ChunkCreate) SetSha256Output(s string) *ChunkCreate

+ func (cc *ChunkCreate) SetSizeContent(i int64) *ChunkCreate

+ func (cc *ChunkCreate) SetSizeInput(i int64) *ChunkCreate

+ func (cc *ChunkCreate) SetSizeOutput(i int64) *ChunkCreate

+ func (cc *ChunkCreate) SetStart(t time.Time) *ChunkCreate

+ func (cc *ChunkCreate) SetState(c chunk.State) *ChunkCreate

+ func (cc *ChunkCreate) SetUpdatedAt(t time.Time) *ChunkCreate

+ func (cc *ChunkCreate) SetWorker(w *Worker) *ChunkCreate

+ func (cc *ChunkCreate) SetWorkerID(id uuid.UUID) *ChunkCreate

+ type ChunkCreateBulk struct

+ func (ccb *ChunkCreateBulk) Exec(ctx context.Context) error

+ func (ccb *ChunkCreateBulk) ExecX(ctx context.Context)

+ func (ccb *ChunkCreateBulk) Save(ctx context.Context) ([]*Chunk, error)

+ func (ccb *ChunkCreateBulk) SaveX(ctx context.Context) []*Chunk

+ type ChunkDelete struct

+ func (cd *ChunkDelete) Exec(ctx context.Context) (int, error)

+ func (cd *ChunkDelete) ExecX(ctx context.Context) int

+ func (cd *ChunkDelete) Where(ps ...predicate.Chunk) *ChunkDelete

+ type ChunkDeleteOne struct

+ func (cdo *ChunkDeleteOne) Exec(ctx context.Context) error

+ func (cdo *ChunkDeleteOne) ExecX(ctx context.Context)

+ type ChunkEdges struct

+ Worker *Worker

+ func (e ChunkEdges) WorkerOrErr() (*Worker, error)

+ type ChunkGroupBy struct

+ func (cgb *ChunkGroupBy) Aggregate(fns ...AggregateFunc) *ChunkGroupBy

+ func (cgb *ChunkGroupBy) Bool(ctx context.Context) (_ bool, err error)

+ func (cgb *ChunkGroupBy) BoolX(ctx context.Context) bool

+ func (cgb *ChunkGroupBy) Bools(ctx context.Context) ([]bool, error)

+ func (cgb *ChunkGroupBy) BoolsX(ctx context.Context) []bool

+ func (cgb *ChunkGroupBy) Float64(ctx context.Context) (_ float64, err error)

+ func (cgb *ChunkGroupBy) Float64X(ctx context.Context) float64

+ func (cgb *ChunkGroupBy) Float64s(ctx context.Context) ([]float64, error)

+ func (cgb *ChunkGroupBy) Float64sX(ctx context.Context) []float64

+ func (cgb *ChunkGroupBy) Int(ctx context.Context) (_ int, err error)

+ func (cgb *ChunkGroupBy) IntX(ctx context.Context) int

+ func (cgb *ChunkGroupBy) Ints(ctx context.Context) ([]int, error)

+ func (cgb *ChunkGroupBy) IntsX(ctx context.Context) []int

+ func (cgb *ChunkGroupBy) Scan(ctx context.Context, v interface{}) error

+ func (cgb *ChunkGroupBy) ScanX(ctx context.Context, v interface{})

+ func (cgb *ChunkGroupBy) String(ctx context.Context) (_ string, err error)

+ func (cgb *ChunkGroupBy) StringX(ctx context.Context) string

+ func (cgb *ChunkGroupBy) Strings(ctx context.Context) ([]string, error)

+ func (cgb *ChunkGroupBy) StringsX(ctx context.Context) []string

+ type ChunkMutation struct

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

+ func (m *ChunkMutation) AddSizeContent(i int64)

+ func (m *ChunkMutation) AddSizeInput(i int64)

+ func (m *ChunkMutation) AddSizeOutput(i int64)

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

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

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

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

+ func (m *ChunkMutation) AddedSizeContent() (r int64, exists bool)

+ func (m *ChunkMutation) AddedSizeInput() (r int64, exists bool)

+ func (m *ChunkMutation) AddedSizeOutput() (r int64, exists bool)

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

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

+ func (m *ChunkMutation) ClearLeaseExpiresAt()

+ func (m *ChunkMutation) ClearSha256Content()

+ func (m *ChunkMutation) ClearSha256Input()

+ func (m *ChunkMutation) ClearSha256Output()

+ func (m *ChunkMutation) ClearSizeContent()

+ func (m *ChunkMutation) ClearSizeInput()

+ func (m *ChunkMutation) ClearSizeOutput()

+ func (m *ChunkMutation) ClearWorker()

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

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

+ func (m *ChunkMutation) CreatedAt() (r time.Time, exists bool)

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

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

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

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

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

+ func (m *ChunkMutation) LeaseExpiresAt() (r time.Time, exists bool)

+ func (m *ChunkMutation) LeaseExpiresAtCleared() bool

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

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

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

+ func (m *ChunkMutation) OldSha256Content(ctx context.Context) (v *string, err error)

+ func (m *ChunkMutation) OldSha256Input(ctx context.Context) (v *string, err error)

+ func (m *ChunkMutation) OldSha256Output(ctx context.Context) (v *string, err error)

+ func (m *ChunkMutation) OldSizeContent(ctx context.Context) (v int64, err error)

+ func (m *ChunkMutation) OldSizeInput(ctx context.Context) (v int64, err error)

+ func (m *ChunkMutation) OldSizeOutput(ctx context.Context) (v int64, err error)

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

+ func (m *ChunkMutation) OldState(ctx context.Context) (v chunk.State, err error)

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

+ func (m *ChunkMutation) Op() Op

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

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

+ func (m *ChunkMutation) ResetCreatedAt()

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

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

+ func (m *ChunkMutation) ResetLeaseExpiresAt()

+ func (m *ChunkMutation) ResetSha256Content()

+ func (m *ChunkMutation) ResetSha256Input()

+ func (m *ChunkMutation) ResetSha256Output()

+ func (m *ChunkMutation) ResetSizeContent()

+ func (m *ChunkMutation) ResetSizeInput()

+ func (m *ChunkMutation) ResetSizeOutput()

+ func (m *ChunkMutation) ResetStart()

+ func (m *ChunkMutation) ResetState()

+ func (m *ChunkMutation) ResetUpdatedAt()

+ func (m *ChunkMutation) ResetWorker()

+ func (m *ChunkMutation) SetCreatedAt(t time.Time)

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

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

+ func (m *ChunkMutation) SetLeaseExpiresAt(t time.Time)

+ func (m *ChunkMutation) SetSha256Content(s string)

+ func (m *ChunkMutation) SetSha256Input(s string)

+ func (m *ChunkMutation) SetSha256Output(s string)

+ func (m *ChunkMutation) SetSizeContent(i int64)

+ func (m *ChunkMutation) SetSizeInput(i int64)

+ func (m *ChunkMutation) SetSizeOutput(i int64)

+ func (m *ChunkMutation) SetStart(t time.Time)

+ func (m *ChunkMutation) SetState(c chunk.State)

+ func (m *ChunkMutation) SetUpdatedAt(t time.Time)

+ func (m *ChunkMutation) SetWorkerID(id uuid.UUID)

+ func (m *ChunkMutation) Sha256Content() (r string, exists bool)

+ func (m *ChunkMutation) Sha256ContentCleared() bool

+ func (m *ChunkMutation) Sha256Input() (r string, exists bool)

+ func (m *ChunkMutation) Sha256InputCleared() bool

+ func (m *ChunkMutation) Sha256Output() (r string, exists bool)

+ func (m *ChunkMutation) Sha256OutputCleared() bool

+ func (m *ChunkMutation) SizeContent() (r int64, exists bool)

+ func (m *ChunkMutation) SizeContentCleared() bool

+ func (m *ChunkMutation) SizeInput() (r int64, exists bool)

+ func (m *ChunkMutation) SizeInputCleared() bool

+ func (m *ChunkMutation) SizeOutput() (r int64, exists bool)

+ func (m *ChunkMutation) SizeOutputCleared() bool

+ func (m *ChunkMutation) Start() (r time.Time, exists bool)

+ func (m *ChunkMutation) State() (r chunk.State, exists bool)

+ func (m *ChunkMutation) Type() string

+ func (m *ChunkMutation) UpdatedAt() (r time.Time, exists bool)

+ func (m *ChunkMutation) Where(ps ...predicate.Chunk)

+ func (m *ChunkMutation) WorkerCleared() bool

+ func (m *ChunkMutation) WorkerID() (id uuid.UUID, exists bool)

+ func (m *ChunkMutation) WorkerIDs() (ids []uuid.UUID)

+ func (m ChunkMutation) Client() *Client

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

+ type ChunkQuery struct

+ func (cq *ChunkQuery) All(ctx context.Context) ([]*Chunk, error)

+ func (cq *ChunkQuery) AllX(ctx context.Context) []*Chunk

+ func (cq *ChunkQuery) Clone() *ChunkQuery

+ func (cq *ChunkQuery) Count(ctx context.Context) (int, error)

+ func (cq *ChunkQuery) CountX(ctx context.Context) int

+ func (cq *ChunkQuery) Exist(ctx context.Context) (bool, error)

+ func (cq *ChunkQuery) ExistX(ctx context.Context) bool

+ func (cq *ChunkQuery) First(ctx context.Context) (*Chunk, error)

+ func (cq *ChunkQuery) FirstID(ctx context.Context) (id string, err error)

+ func (cq *ChunkQuery) FirstIDX(ctx context.Context) string

+ func (cq *ChunkQuery) FirstX(ctx context.Context) *Chunk

+ func (cq *ChunkQuery) ForShare(opts ...sql.LockOption) *ChunkQuery

+ func (cq *ChunkQuery) ForUpdate(opts ...sql.LockOption) *ChunkQuery

+ func (cq *ChunkQuery) GroupBy(field string, fields ...string) *ChunkGroupBy

+ func (cq *ChunkQuery) IDs(ctx context.Context) ([]string, error)

+ func (cq *ChunkQuery) IDsX(ctx context.Context) []string

+ func (cq *ChunkQuery) Limit(limit int) *ChunkQuery

+ func (cq *ChunkQuery) Offset(offset int) *ChunkQuery

+ func (cq *ChunkQuery) Only(ctx context.Context) (*Chunk, error)

+ func (cq *ChunkQuery) OnlyID(ctx context.Context) (id string, err error)

+ func (cq *ChunkQuery) OnlyIDX(ctx context.Context) string

+ func (cq *ChunkQuery) OnlyX(ctx context.Context) *Chunk

+ func (cq *ChunkQuery) Order(o ...OrderFunc) *ChunkQuery

+ func (cq *ChunkQuery) QueryWorker() *WorkerQuery

+ func (cq *ChunkQuery) Select(fields ...string) *ChunkSelect

+ func (cq *ChunkQuery) Unique(unique bool) *ChunkQuery

+ func (cq *ChunkQuery) Where(ps ...predicate.Chunk) *ChunkQuery

+ func (cq *ChunkQuery) WithWorker(opts ...func(*WorkerQuery)) *ChunkQuery

+ type ChunkSelect struct

+ func (cs *ChunkSelect) Bool(ctx context.Context) (_ bool, err error)

+ func (cs *ChunkSelect) BoolX(ctx context.Context) bool

+ func (cs *ChunkSelect) Bools(ctx context.Context) ([]bool, error)

+ func (cs *ChunkSelect) BoolsX(ctx context.Context) []bool

+ func (cs *ChunkSelect) Float64(ctx context.Context) (_ float64, err error)

+ func (cs *ChunkSelect) Float64X(ctx context.Context) float64

+ func (cs *ChunkSelect) Float64s(ctx context.Context) ([]float64, error)

+ func (cs *ChunkSelect) Float64sX(ctx context.Context) []float64

+ func (cs *ChunkSelect) Int(ctx context.Context) (_ int, err error)

+ func (cs *ChunkSelect) IntX(ctx context.Context) int

+ func (cs *ChunkSelect) Ints(ctx context.Context) ([]int, error)

+ func (cs *ChunkSelect) IntsX(ctx context.Context) []int

+ func (cs *ChunkSelect) Scan(ctx context.Context, v interface{}) error

+ func (cs *ChunkSelect) ScanX(ctx context.Context, v interface{})

+ func (cs *ChunkSelect) String(ctx context.Context) (_ string, err error)

+ func (cs *ChunkSelect) StringX(ctx context.Context) string

+ func (cs *ChunkSelect) Strings(ctx context.Context) ([]string, error)

+ func (cs *ChunkSelect) StringsX(ctx context.Context) []string

+ type ChunkUpdate struct

+ func (cu *ChunkUpdate) AddSizeContent(i int64) *ChunkUpdate

+ func (cu *ChunkUpdate) AddSizeInput(i int64) *ChunkUpdate

+ func (cu *ChunkUpdate) AddSizeOutput(i int64) *ChunkUpdate

+ func (cu *ChunkUpdate) ClearLeaseExpiresAt() *ChunkUpdate

+ func (cu *ChunkUpdate) ClearSha256Content() *ChunkUpdate

+ func (cu *ChunkUpdate) ClearSha256Input() *ChunkUpdate

+ func (cu *ChunkUpdate) ClearSha256Output() *ChunkUpdate

+ func (cu *ChunkUpdate) ClearSizeContent() *ChunkUpdate

+ func (cu *ChunkUpdate) ClearSizeInput() *ChunkUpdate

+ func (cu *ChunkUpdate) ClearSizeOutput() *ChunkUpdate

+ func (cu *ChunkUpdate) ClearWorker() *ChunkUpdate

+ func (cu *ChunkUpdate) Exec(ctx context.Context) error

+ func (cu *ChunkUpdate) ExecX(ctx context.Context)

+ func (cu *ChunkUpdate) Mutation() *ChunkMutation

+ func (cu *ChunkUpdate) Save(ctx context.Context) (int, error)

+ func (cu *ChunkUpdate) SaveX(ctx context.Context) int

+ func (cu *ChunkUpdate) SetLeaseExpiresAt(t time.Time) *ChunkUpdate

+ func (cu *ChunkUpdate) SetNillableLeaseExpiresAt(t *time.Time) *ChunkUpdate

+ func (cu *ChunkUpdate) SetNillableSha256Content(s *string) *ChunkUpdate

+ func (cu *ChunkUpdate) SetNillableSha256Input(s *string) *ChunkUpdate

+ func (cu *ChunkUpdate) SetNillableSha256Output(s *string) *ChunkUpdate

+ func (cu *ChunkUpdate) SetNillableSizeContent(i *int64) *ChunkUpdate

+ func (cu *ChunkUpdate) SetNillableSizeInput(i *int64) *ChunkUpdate

+ func (cu *ChunkUpdate) SetNillableSizeOutput(i *int64) *ChunkUpdate

+ func (cu *ChunkUpdate) SetNillableState(c *chunk.State) *ChunkUpdate

+ func (cu *ChunkUpdate) SetNillableWorkerID(id *uuid.UUID) *ChunkUpdate

+ func (cu *ChunkUpdate) SetSha256Content(s string) *ChunkUpdate

+ func (cu *ChunkUpdate) SetSha256Input(s string) *ChunkUpdate

+ func (cu *ChunkUpdate) SetSha256Output(s string) *ChunkUpdate

+ func (cu *ChunkUpdate) SetSizeContent(i int64) *ChunkUpdate

+ func (cu *ChunkUpdate) SetSizeInput(i int64) *ChunkUpdate

+ func (cu *ChunkUpdate) SetSizeOutput(i int64) *ChunkUpdate

+ func (cu *ChunkUpdate) SetStart(t time.Time) *ChunkUpdate

+ func (cu *ChunkUpdate) SetState(c chunk.State) *ChunkUpdate

+ func (cu *ChunkUpdate) SetUpdatedAt(t time.Time) *ChunkUpdate

+ func (cu *ChunkUpdate) SetWorker(w *Worker) *ChunkUpdate

+ func (cu *ChunkUpdate) SetWorkerID(id uuid.UUID) *ChunkUpdate

+ func (cu *ChunkUpdate) Where(ps ...predicate.Chunk) *ChunkUpdate

+ type ChunkUpdateOne struct

+ func (cuo *ChunkUpdateOne) AddSizeContent(i int64) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) AddSizeInput(i int64) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) AddSizeOutput(i int64) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) ClearLeaseExpiresAt() *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) ClearSha256Content() *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) ClearSha256Input() *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) ClearSha256Output() *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) ClearSizeContent() *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) ClearSizeInput() *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) ClearSizeOutput() *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) ClearWorker() *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) Exec(ctx context.Context) error

+ func (cuo *ChunkUpdateOne) ExecX(ctx context.Context)

+ func (cuo *ChunkUpdateOne) Mutation() *ChunkMutation

+ func (cuo *ChunkUpdateOne) Save(ctx context.Context) (*Chunk, error)

+ func (cuo *ChunkUpdateOne) SaveX(ctx context.Context) *Chunk

+ func (cuo *ChunkUpdateOne) Select(field string, fields ...string) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetLeaseExpiresAt(t time.Time) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetNillableLeaseExpiresAt(t *time.Time) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetNillableSha256Content(s *string) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetNillableSha256Input(s *string) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetNillableSha256Output(s *string) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetNillableSizeContent(i *int64) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetNillableSizeInput(i *int64) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetNillableSizeOutput(i *int64) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetNillableState(c *chunk.State) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetNillableWorkerID(id *uuid.UUID) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetSha256Content(s string) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetSha256Input(s string) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetSha256Output(s string) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetSizeContent(i int64) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetSizeInput(i int64) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetSizeOutput(i int64) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetStart(t time.Time) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetState(c chunk.State) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetUpdatedAt(t time.Time) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetWorker(w *Worker) *ChunkUpdateOne

+ func (cuo *ChunkUpdateOne) SetWorkerID(id uuid.UUID) *ChunkUpdateOne

+ type Chunks []*Chunk

+ type Client struct

+ Chunk *ChunkClient

+ Schema *migrate.Schema

+ Worker *WorkerClient

+ 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) 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 Hook = ent.Hook

+ 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(...interface{})) Option

+ type OrderFunc func(*sql.Selector)

+ func Asc(fields ...string) OrderFunc

+ func Desc(fields ...string) OrderFunc

+ type Policy = ent.Policy

+ type Query = ent.Query

+ 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 Tx struct

+ Chunk *ChunkClient

+ Worker *WorkerClient

+ 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

+ type Worker struct

+ CreatedAt time.Time

+ Edges WorkerEdges

+ ID uuid.UUID

+ Name string

+ Token string

+ UpdatedAt time.Time

+ func (w *Worker) QueryChunks() *ChunkQuery

+ func (w *Worker) String() string

+ func (w *Worker) Unwrap() *Worker

+ func (w *Worker) Update() *WorkerUpdateOne

+ type WorkerClient struct

+ func NewWorkerClient(c config) *WorkerClient

+ func (c *WorkerClient) Create() *WorkerCreate

+ func (c *WorkerClient) CreateBulk(builders ...*WorkerCreate) *WorkerCreateBulk

+ func (c *WorkerClient) Delete() *WorkerDelete

+ func (c *WorkerClient) DeleteOne(w *Worker) *WorkerDeleteOne

+ func (c *WorkerClient) DeleteOneID(id uuid.UUID) *WorkerDeleteOne

+ func (c *WorkerClient) Get(ctx context.Context, id uuid.UUID) (*Worker, error)

+ func (c *WorkerClient) GetX(ctx context.Context, id uuid.UUID) *Worker

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

+ func (c *WorkerClient) Query() *WorkerQuery

+ func (c *WorkerClient) QueryChunks(w *Worker) *ChunkQuery

+ func (c *WorkerClient) Update() *WorkerUpdate

+ func (c *WorkerClient) UpdateOne(w *Worker) *WorkerUpdateOne

+ func (c *WorkerClient) UpdateOneID(id uuid.UUID) *WorkerUpdateOne

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

+ type WorkerCreate struct

+ func (wc *WorkerCreate) AddChunkIDs(ids ...string) *WorkerCreate

+ func (wc *WorkerCreate) AddChunks(c ...*Chunk) *WorkerCreate

+ func (wc *WorkerCreate) Exec(ctx context.Context) error

+ func (wc *WorkerCreate) ExecX(ctx context.Context)

+ func (wc *WorkerCreate) Mutation() *WorkerMutation

+ func (wc *WorkerCreate) Save(ctx context.Context) (*Worker, error)

+ func (wc *WorkerCreate) SaveX(ctx context.Context) *Worker

+ func (wc *WorkerCreate) SetCreatedAt(t time.Time) *WorkerCreate

+ func (wc *WorkerCreate) SetID(u uuid.UUID) *WorkerCreate

+ func (wc *WorkerCreate) SetName(s string) *WorkerCreate

+ func (wc *WorkerCreate) SetNillableCreatedAt(t *time.Time) *WorkerCreate

+ func (wc *WorkerCreate) SetNillableUpdatedAt(t *time.Time) *WorkerCreate

+ func (wc *WorkerCreate) SetToken(s string) *WorkerCreate

+ func (wc *WorkerCreate) SetUpdatedAt(t time.Time) *WorkerCreate

+ type WorkerCreateBulk struct

+ func (wcb *WorkerCreateBulk) Exec(ctx context.Context) error

+ func (wcb *WorkerCreateBulk) ExecX(ctx context.Context)

+ func (wcb *WorkerCreateBulk) Save(ctx context.Context) ([]*Worker, error)

+ func (wcb *WorkerCreateBulk) SaveX(ctx context.Context) []*Worker

+ type WorkerDelete struct

+ func (wd *WorkerDelete) Exec(ctx context.Context) (int, error)

+ func (wd *WorkerDelete) ExecX(ctx context.Context) int

+ func (wd *WorkerDelete) Where(ps ...predicate.Worker) *WorkerDelete

+ type WorkerDeleteOne struct

+ func (wdo *WorkerDeleteOne) Exec(ctx context.Context) error

+ func (wdo *WorkerDeleteOne) ExecX(ctx context.Context)

+ type WorkerEdges struct

+ Chunks []*Chunk

+ func (e WorkerEdges) ChunksOrErr() ([]*Chunk, error)

+ type WorkerGroupBy struct

+ func (wgb *WorkerGroupBy) Aggregate(fns ...AggregateFunc) *WorkerGroupBy

+ func (wgb *WorkerGroupBy) Bool(ctx context.Context) (_ bool, err error)

+ func (wgb *WorkerGroupBy) BoolX(ctx context.Context) bool

+ func (wgb *WorkerGroupBy) Bools(ctx context.Context) ([]bool, error)

+ func (wgb *WorkerGroupBy) BoolsX(ctx context.Context) []bool

+ func (wgb *WorkerGroupBy) Float64(ctx context.Context) (_ float64, err error)

+ func (wgb *WorkerGroupBy) Float64X(ctx context.Context) float64

+ func (wgb *WorkerGroupBy) Float64s(ctx context.Context) ([]float64, error)

+ func (wgb *WorkerGroupBy) Float64sX(ctx context.Context) []float64

+ func (wgb *WorkerGroupBy) Int(ctx context.Context) (_ int, err error)

+ func (wgb *WorkerGroupBy) IntX(ctx context.Context) int

+ func (wgb *WorkerGroupBy) Ints(ctx context.Context) ([]int, error)

+ func (wgb *WorkerGroupBy) IntsX(ctx context.Context) []int

+ func (wgb *WorkerGroupBy) Scan(ctx context.Context, v interface{}) error

+ func (wgb *WorkerGroupBy) ScanX(ctx context.Context, v interface{})

+ func (wgb *WorkerGroupBy) String(ctx context.Context) (_ string, err error)

+ func (wgb *WorkerGroupBy) StringX(ctx context.Context) string

+ func (wgb *WorkerGroupBy) Strings(ctx context.Context) ([]string, error)

+ func (wgb *WorkerGroupBy) StringsX(ctx context.Context) []string

+ type WorkerMutation struct

+ func (m *WorkerMutation) AddChunkIDs(ids ...string)

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

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

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

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

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

+ func (m *WorkerMutation) ChunksCleared() bool

+ func (m *WorkerMutation) ChunksIDs() (ids []string)

+ func (m *WorkerMutation) ClearChunks()

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

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

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

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

+ func (m *WorkerMutation) CreatedAt() (r time.Time, exists bool)

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

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

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

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

+ func (m *WorkerMutation) ID() (id uuid.UUID, exists bool)

+ func (m *WorkerMutation) Name() (r string, exists bool)

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

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

+ func (m *WorkerMutation) OldName(ctx context.Context) (v string, err error)

+ func (m *WorkerMutation) OldToken(ctx context.Context) (v string, err error)

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

+ func (m *WorkerMutation) Op() Op

+ func (m *WorkerMutation) RemoveChunkIDs(ids ...string)

+ func (m *WorkerMutation) RemovedChunksIDs() (ids []string)

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

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

+ func (m *WorkerMutation) ResetChunks()

+ func (m *WorkerMutation) ResetCreatedAt()

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

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

+ func (m *WorkerMutation) ResetName()

+ func (m *WorkerMutation) ResetToken()

+ func (m *WorkerMutation) ResetUpdatedAt()

+ func (m *WorkerMutation) SetCreatedAt(t time.Time)

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

+ func (m *WorkerMutation) SetID(id uuid.UUID)

+ func (m *WorkerMutation) SetName(s string)

+ func (m *WorkerMutation) SetToken(s string)

+ func (m *WorkerMutation) SetUpdatedAt(t time.Time)

+ func (m *WorkerMutation) Token() (r string, exists bool)

+ func (m *WorkerMutation) Type() string

+ func (m *WorkerMutation) UpdatedAt() (r time.Time, exists bool)

+ func (m *WorkerMutation) Where(ps ...predicate.Worker)

+ func (m WorkerMutation) Client() *Client

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

+ type WorkerQuery struct

+ func (wq *WorkerQuery) All(ctx context.Context) ([]*Worker, error)

+ func (wq *WorkerQuery) AllX(ctx context.Context) []*Worker

+ func (wq *WorkerQuery) Clone() *WorkerQuery

+ func (wq *WorkerQuery) Count(ctx context.Context) (int, error)

+ func (wq *WorkerQuery) CountX(ctx context.Context) int

+ func (wq *WorkerQuery) Exist(ctx context.Context) (bool, error)

+ func (wq *WorkerQuery) ExistX(ctx context.Context) bool

+ func (wq *WorkerQuery) First(ctx context.Context) (*Worker, error)

+ func (wq *WorkerQuery) FirstID(ctx context.Context) (id uuid.UUID, err error)

+ func (wq *WorkerQuery) FirstIDX(ctx context.Context) uuid.UUID

+ func (wq *WorkerQuery) FirstX(ctx context.Context) *Worker

+ func (wq *WorkerQuery) ForShare(opts ...sql.LockOption) *WorkerQuery

+ func (wq *WorkerQuery) ForUpdate(opts ...sql.LockOption) *WorkerQuery

+ func (wq *WorkerQuery) GroupBy(field string, fields ...string) *WorkerGroupBy

+ func (wq *WorkerQuery) IDs(ctx context.Context) ([]uuid.UUID, error)

+ func (wq *WorkerQuery) IDsX(ctx context.Context) []uuid.UUID

+ func (wq *WorkerQuery) Limit(limit int) *WorkerQuery

+ func (wq *WorkerQuery) Offset(offset int) *WorkerQuery

+ func (wq *WorkerQuery) Only(ctx context.Context) (*Worker, error)

+ func (wq *WorkerQuery) OnlyID(ctx context.Context) (id uuid.UUID, err error)

+ func (wq *WorkerQuery) OnlyIDX(ctx context.Context) uuid.UUID

+ func (wq *WorkerQuery) OnlyX(ctx context.Context) *Worker

+ func (wq *WorkerQuery) Order(o ...OrderFunc) *WorkerQuery

+ func (wq *WorkerQuery) QueryChunks() *ChunkQuery

+ func (wq *WorkerQuery) Select(fields ...string) *WorkerSelect

+ func (wq *WorkerQuery) Unique(unique bool) *WorkerQuery

+ func (wq *WorkerQuery) Where(ps ...predicate.Worker) *WorkerQuery

+ func (wq *WorkerQuery) WithChunks(opts ...func(*ChunkQuery)) *WorkerQuery

+ type WorkerSelect struct

+ func (ws *WorkerSelect) Bool(ctx context.Context) (_ bool, err error)

+ func (ws *WorkerSelect) BoolX(ctx context.Context) bool

+ func (ws *WorkerSelect) Bools(ctx context.Context) ([]bool, error)

+ func (ws *WorkerSelect) BoolsX(ctx context.Context) []bool

+ func (ws *WorkerSelect) Float64(ctx context.Context) (_ float64, err error)

+ func (ws *WorkerSelect) Float64X(ctx context.Context) float64

+ func (ws *WorkerSelect) Float64s(ctx context.Context) ([]float64, error)

+ func (ws *WorkerSelect) Float64sX(ctx context.Context) []float64

+ func (ws *WorkerSelect) Int(ctx context.Context) (_ int, err error)

+ func (ws *WorkerSelect) IntX(ctx context.Context) int

+ func (ws *WorkerSelect) Ints(ctx context.Context) ([]int, error)

+ func (ws *WorkerSelect) IntsX(ctx context.Context) []int

+ func (ws *WorkerSelect) Scan(ctx context.Context, v interface{}) error

+ func (ws *WorkerSelect) ScanX(ctx context.Context, v interface{})

+ func (ws *WorkerSelect) String(ctx context.Context) (_ string, err error)

+ func (ws *WorkerSelect) StringX(ctx context.Context) string

+ func (ws *WorkerSelect) Strings(ctx context.Context) ([]string, error)

+ func (ws *WorkerSelect) StringsX(ctx context.Context) []string

+ type WorkerUpdate struct

+ func (wu *WorkerUpdate) AddChunkIDs(ids ...string) *WorkerUpdate

+ func (wu *WorkerUpdate) AddChunks(c ...*Chunk) *WorkerUpdate

+ func (wu *WorkerUpdate) ClearChunks() *WorkerUpdate

+ func (wu *WorkerUpdate) Exec(ctx context.Context) error

+ func (wu *WorkerUpdate) ExecX(ctx context.Context)

+ func (wu *WorkerUpdate) Mutation() *WorkerMutation

+ func (wu *WorkerUpdate) RemoveChunkIDs(ids ...string) *WorkerUpdate

+ func (wu *WorkerUpdate) RemoveChunks(c ...*Chunk) *WorkerUpdate

+ func (wu *WorkerUpdate) Save(ctx context.Context) (int, error)

+ func (wu *WorkerUpdate) SaveX(ctx context.Context) int

+ func (wu *WorkerUpdate) SetName(s string) *WorkerUpdate

+ func (wu *WorkerUpdate) SetToken(s string) *WorkerUpdate

+ func (wu *WorkerUpdate) SetUpdatedAt(t time.Time) *WorkerUpdate

+ func (wu *WorkerUpdate) Where(ps ...predicate.Worker) *WorkerUpdate

+ type WorkerUpdateOne struct

+ func (wuo *WorkerUpdateOne) AddChunkIDs(ids ...string) *WorkerUpdateOne

+ func (wuo *WorkerUpdateOne) AddChunks(c ...*Chunk) *WorkerUpdateOne

+ func (wuo *WorkerUpdateOne) ClearChunks() *WorkerUpdateOne

+ func (wuo *WorkerUpdateOne) Exec(ctx context.Context) error

+ func (wuo *WorkerUpdateOne) ExecX(ctx context.Context)

+ func (wuo *WorkerUpdateOne) Mutation() *WorkerMutation

+ func (wuo *WorkerUpdateOne) RemoveChunkIDs(ids ...string) *WorkerUpdateOne

+ func (wuo *WorkerUpdateOne) RemoveChunks(c ...*Chunk) *WorkerUpdateOne

+ func (wuo *WorkerUpdateOne) Save(ctx context.Context) (*Worker, error)

+ func (wuo *WorkerUpdateOne) SaveX(ctx context.Context) *Worker

+ func (wuo *WorkerUpdateOne) Select(field string, fields ...string) *WorkerUpdateOne

+ func (wuo *WorkerUpdateOne) SetName(s string) *WorkerUpdateOne

+ func (wuo *WorkerUpdateOne) SetToken(s string) *WorkerUpdateOne

+ func (wuo *WorkerUpdateOne) SetUpdatedAt(t time.Time) *WorkerUpdateOne

+ type Workers []*Worker

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