runtime

Documentation

Index

• func AddEnt(v ...Entity)
• func RegisterRepo(g *GroupVersionKind, fn func(Entity) Repo)
• type Entity
  • func NewEntWithGVK(gvk *GroupVersionKind) (Entity, bool)
  • func NewEntity(gvk string) (Entity, bool)
• type EntitySet
  • func NewEntitySet() *EntitySet
  • func (os *EntitySet) AddEnt(v ...Entity)
  • func (os *EntitySet) GetEntity(gvk *GroupVersionKind) (Entity, bool)
  • func (os *EntitySet) IsExists(gvk *GroupVersionKind) bool
  • func (os *EntitySet) NewEntWithGVK(gvk *GroupVersionKind) (Entity, bool)
  • func (os *EntitySet) NewEntity(gvk string) (Entity, bool)
• type GroupVersionKind
  • func FromGVK(s string) *GroupVersionKind
  • func (gvk *GroupVersionKind) APIGroup() string
  • func (gvk *GroupVersionKind) String() string
• type Repo
  • func NewRepo(in Entity) (Repo, bool)
• type RepoSet
  • func NewRepoSet() *RepoSet
  • func (s *RepoSet) NewRepo(in Entity) (Repo, bool)
  • func (s *RepoSet) RegisterRepo(g *GroupVersionKind, fn func(Entity) Repo)

Functions

func AddEnt

func AddEnt(v ...Entity)

func RegisterRepo

func RegisterRepo(g *GroupVersionKind, fn func(Entity) Repo)

Types

type Entity

type Entity interface {
	// GVK get the GroupVersionKind of Entity
	GVK() *GroupVersionKind
	// DeepCopyFrom deep copy the struct from another
	DeepCopyFrom(Entity)
	// DeepCopy deep copy the struct
	DeepCopy() Entity
}

Entity is an interface that describes protocol message

func NewEntWithGVK

func NewEntWithGVK(gvk *GroupVersionKind) (Entity, bool)

NewEntWithGVK creates a new entity, trigger OnCreate function

func NewEntity

func NewEntity(gvk string) (Entity, bool)

NewEntity creates a new entity, trigger OnCreate function

type EntitySet

type EntitySet struct {
	sync.RWMutex

	OnCreate func(in Entity) Entity
	// contains filtered or unexported fields
}

func NewEntitySet

func NewEntitySet() *EntitySet

func (*EntitySet) AddEnt

func (os *EntitySet) AddEnt(v ...Entity)

AddEnt push entities to Set

func (*EntitySet) GetEntity

func (os *EntitySet) GetEntity(gvk *GroupVersionKind) (Entity, bool)

func (*EntitySet) IsExists

func (os *EntitySet) IsExists(gvk *GroupVersionKind) bool

func (*EntitySet) NewEntWithGVK

func (os *EntitySet) NewEntWithGVK(gvk *GroupVersionKind) (Entity, bool)

NewEntWithGVK creates a new entity, trigger OnCreate function

func (*EntitySet) NewEntity

func (os *EntitySet) NewEntity(gvk string) (Entity, bool)

NewEntity creates a new entity, trigger OnCreate function

type GroupVersionKind

type GroupVersionKind struct {
	Group   string
	Version string
	Kind    string
}

GroupVersionKind contains the information of Entity, etc Group, Version, Kind

func FromGVK

func FromGVK(s string) *GroupVersionKind

func (*GroupVersionKind) APIGroup

func (gvk *GroupVersionKind) APIGroup() string

func (*GroupVersionKind) String

func (gvk *GroupVersionKind) String() string

type Repo

type Repo interface {
	FindPage(ctx context.Context, page, size int32) ([]Entity, int64, error)
	FindAll(ctx context.Context) ([]Entity, error)
	FindPureAll(ctx context.Context) ([]Entity, error)
	Count(ctx context.Context) (total int64, err error)
	FindOne(ctx context.Context) (Entity, error)
	FindPureOne(ctx context.Context) (Entity, error)
	Cond(exprs ...clause.Expression) Repo
	Create(ctx context.Context) (Entity, error)
	BatchUpdates(ctx context.Context) error
	Updates(ctx context.Context) (Entity, error)
	BatchDelete(ctx context.Context, soft bool) error
	Delete(ctx context.Context, soft bool) error
	Tx(ctx context.Context) *dao.DB
}

func NewRepo

func NewRepo(in Entity) (Repo, bool)

type RepoSet

type RepoSet struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRepoSet

func NewRepoSet() *RepoSet

func (*RepoSet) NewRepo

func (s *RepoSet) NewRepo(in Entity) (Repo, bool)

func (*RepoSet) RegisterRepo

func (s *RepoSet) RegisterRepo(g *GroupVersionKind, fn func(Entity) Repo)