invocationdb

Documentation

Index

• type InvocationDB
  • func NewInvocationDB(env environment.Env, h *db.DBHandle) *InvocationDB
  • func (d *InvocationDB) DeleteInvocation(ctx context.Context, invocationID string) error
  • func (d *InvocationDB) FillCounts(ctx context.Context, stat *telpb.TelemetryStat) error
  • func (d *InvocationDB) InsertOrUpdateInvocation(ctx context.Context, ti *tables.Invocation) error
  • func (d *InvocationDB) LookupExpiredInvocations(ctx context.Context, cutoffTime time.Time, limit int) ([]*tables.Invocation, error)
  • func (d *InvocationDB) LookupGroupFromInvocation(ctx context.Context, invocationID string) (*tables.Group, error)
  • func (d *InvocationDB) LookupInvocation(ctx context.Context, invocationID string) (*tables.Invocation, error)

Types

type InvocationDB

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

func NewInvocationDB

func NewInvocationDB(env environment.Env, h *db.DBHandle) *InvocationDB

func (*InvocationDB) DeleteInvocation

func (d *InvocationDB) DeleteInvocation(ctx context.Context, invocationID string) error

func (*InvocationDB) FillCounts

func (d *InvocationDB) FillCounts(ctx context.Context, stat *telpb.TelemetryStat) error

func (*InvocationDB) InsertOrUpdateInvocation

func (d *InvocationDB) InsertOrUpdateInvocation(ctx context.Context, ti *tables.Invocation) error

func (*InvocationDB) LookupExpiredInvocations

func (d *InvocationDB) LookupExpiredInvocations(ctx context.Context, cutoffTime time.Time, limit int) ([]*tables.Invocation, error)

func (*InvocationDB) LookupGroupFromInvocation

func (d *InvocationDB) LookupGroupFromInvocation(ctx context.Context, invocationID string) (*tables.Group, error)

func (*InvocationDB) LookupInvocation

func (d *InvocationDB) LookupInvocation(ctx context.Context, invocationID string) (*tables.Invocation, error)