dao

Documentation

Index

• type ConsumerDao
  • func NewConsumerDao(sessionFactory *db.SessionFactory) ConsumerDao
• type EventDao
  • func NewEventDao(sessionFactory *db.SessionFactory) EventDao
• type EventInstanceDao
  • func NewEventInstanceDao(sessionFactory *db.SessionFactory) EventInstanceDao
• type GenericDao
  • func NewGenericDao(sessionFactory *db.SessionFactory) GenericDao
• type InstanceDao
  • func NewInstanceDao(sessionFactory *db.SessionFactory) InstanceDao
• type ResourceDao
  • func NewResourceDao(sessionFactory *db.SessionFactory) ResourceDao
• type StatusEventDao
  • func NewStatusEventDao(sessionFactory *db.SessionFactory) StatusEventDao
• type TableRelation

Types

type ConsumerDao

type ConsumerDao interface {
	Get(ctx context.Context, id string) (*api.Consumer, error)
	Create(ctx context.Context, consumer *api.Consumer) (*api.Consumer, error)
	Replace(ctx context.Context, consumer *api.Consumer) (*api.Consumer, error)
	Delete(ctx context.Context, id string, unscoped bool) error
	FindByIDs(ctx context.Context, ids []string) (api.ConsumerList, error)
	All(ctx context.Context) (api.ConsumerList, error)
}

func NewConsumerDao

func NewConsumerDao(sessionFactory *db.SessionFactory) ConsumerDao

type EventDao

type EventDao interface {
	Get(ctx context.Context, id string) (*api.Event, error)
	Create(ctx context.Context, event *api.Event) (*api.Event, error)
	Replace(ctx context.Context, event *api.Event) (*api.Event, error)
	Delete(ctx context.Context, id string) error
	FindByIDs(ctx context.Context, ids []string) (api.EventList, error)
	All(ctx context.Context) (api.EventList, error)

	DeleteAllReconciledEvents(ctx context.Context) error
	FindAllUnreconciledEvents(ctx context.Context) (api.EventList, error)
}

func NewEventDao

func NewEventDao(sessionFactory *db.SessionFactory) EventDao

type EventInstanceDao

type EventInstanceDao interface {
	Get(ctx context.Context, eventID, instanceID string) (*api.EventInstance, error)
	Create(ctx context.Context, eventInstance *api.EventInstance) (*api.EventInstance, error)

	FindStatusEvents(ctx context.Context, ids []string) (api.EventInstanceList, error)
	GetEventsAssociatedWithInstances(ctx context.Context, instanceIDs []string) ([]string, error)
}

func NewEventInstanceDao

func NewEventInstanceDao(sessionFactory *db.SessionFactory) EventInstanceDao

type GenericDao

type GenericDao interface {
	Fetch(offset int, limit int, resourceList interface{}) error

	GetInstanceDao(ctx context.Context, model interface{}) GenericDao
	Preload(preload string)
	OrderBy(orderBy string)
	Joins(sql string)
	Group(sql string)
	Where(sql string, values []interface{})
	Count(model interface{}, total *int64)
	Validate(resourceList interface{}) error

	GetTableName() string
	GetTableRelation(fieldName string) (TableRelation, bool)
}

func NewGenericDao

func NewGenericDao(sessionFactory *db.SessionFactory) GenericDao

type InstanceDao

type InstanceDao interface {
	Get(ctx context.Context, id string) (*api.ServerInstance, error)
	Create(ctx context.Context, instance *api.ServerInstance) (*api.ServerInstance, error)
	Replace(ctx context.Context, instance *api.ServerInstance) (*api.ServerInstance, error)
	MarkReadyByIDs(ctx context.Context, ids []string) error
	MarkUnreadyByIDs(ctx context.Context, ids []string) error
	Delete(ctx context.Context, id string) error
	DeleteByIDs(ctx context.Context, ids []string) error
	FindByIDs(ctx context.Context, ids []string) (api.ServerInstanceList, error)
	FindByUpdatedTime(ctx context.Context, updatedTime time.Time) (api.ServerInstanceList, error)
	FindReadyIDs(ctx context.Context) ([]string, error)
	All(ctx context.Context) (api.ServerInstanceList, error)
}

func NewInstanceDao

func NewInstanceDao(sessionFactory *db.SessionFactory) InstanceDao

type ResourceDao

type ResourceDao interface {
	Get(ctx context.Context, id string) (*api.Resource, error)
	Create(ctx context.Context, resource *api.Resource) (*api.Resource, error)
	Update(ctx context.Context, resource *api.Resource) (*api.Resource, error)
	Delete(ctx context.Context, id string, unscoped bool) error
	FindByIDs(ctx context.Context, ids []string) (api.ResourceList, error)
	FindBySource(ctx context.Context, source string) (api.ResourceList, error)
	FindByConsumerName(ctx context.Context, consumerName string) (api.ResourceList, error)
	All(ctx context.Context) (api.ResourceList, error)
	FirstByConsumerName(ctx context.Context, name string, unscoped bool) (api.Resource, error)
}

func NewResourceDao

func NewResourceDao(sessionFactory *db.SessionFactory) ResourceDao

type StatusEventDao

type StatusEventDao interface {
	Get(ctx context.Context, id string) (*api.StatusEvent, error)
	Create(ctx context.Context, statusEvent *api.StatusEvent) (*api.StatusEvent, error)
	Replace(ctx context.Context, statusEvent *api.StatusEvent) (*api.StatusEvent, error)
	Delete(ctx context.Context, id string) error
	FindByIDs(ctx context.Context, ids []string) (api.StatusEventList, error)
	All(ctx context.Context) (api.StatusEventList, error)

	DeleteAllReconciledEvents(ctx context.Context) error
	DeleteAllEvents(ctx context.Context, eventIDs []string) error
	FindAllUnreconciledEvents(ctx context.Context) (api.StatusEventList, error)
}

func NewStatusEventDao

func NewStatusEventDao(sessionFactory *db.SessionFactory) StatusEventDao

type TableRelation

type TableRelation struct {
	TableName         string
	ColumnName        string
	ForeignTableName  string
	ForeignColumnName string
}

represents a relationship between two tables. They can be joined, ON TableName.ColumnName = ForeignTableName.ForeignColumnName