dao

Documentation

Index

• type ConsumerDao
  • func NewConsumerDao(sessionFactory *db.SessionFactory) ConsumerDao
• type EventDao
  • func NewEventDao(sessionFactory *db.SessionFactory) EventDao
• 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 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) 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 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)
	UpSert(ctx context.Context, instance *api.ServerInstance) (*api.ServerInstance, 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) 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)
}

func NewResourceDao

func NewResourceDao(sessionFactory *db.SessionFactory) ResourceDao

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