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)
}

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)
	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)
	FindByConsumerNameAndResourceType(ctx context.Context, consumerName string, resourceType api.ResourceType) (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
	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