db

Documentation

Index

• type Client
  • func (client *Client) CountPipelineSource(ops ...mysqlxorm.SessionOption) (int64, error)
  • func (client *Client) CreatePipelineSource(pipelineSource *PipelineSource, ops ...mysqlxorm.SessionOption) (err error)
  • func (client *Client) DeletePipelineSource(id string, pipelineSource *PipelineSource, ops ...mysqlxorm.SessionOption) error
  • func (client *Client) GetPipelineSource(id string, ops ...mysqlxorm.SessionOption) (*PipelineSource, error)
  • func (client *Client) GetPipelineSourceByUnique(unique *PipelineSourceUnique, ops ...mysqlxorm.SessionOption) ([]PipelineSource, error)
  • func (client *Client) GetUniqueSourceGroup(ops ...mysqlxorm.SessionOption) (uniqueSourceGroup []PipelineSourceUniqueGroupWithCount, err error)
  • func (client *Client) ListPipelineSource(idList []string, ops ...mysqlxorm.SessionOption) ([]PipelineSource, error)
  • func (client *Client) ListPipelineSourceByRemote(remote string, ops ...mysqlxorm.SessionOption) ([]PipelineSource, error)
  • func (client *Client) UpdatePipelineSource(id string, pipelineSource *PipelineSource, ops ...mysqlxorm.SessionOption) error
• type PipelineSource
  • func (p *PipelineSource) Convert() *pb.PipelineSource
  • func (PipelineSource) TableName() string
• type PipelineSourceUnique
• type PipelineSourceUniqueGroupWithCount

Types

type Client

type Client struct {
	mysqlxorm.Interface
}

func (*Client) CountPipelineSource

func (client *Client) CountPipelineSource(ops ...mysqlxorm.SessionOption) (int64, error)

func (*Client) CreatePipelineSource

func (client *Client) CreatePipelineSource(pipelineSource *PipelineSource, ops ...mysqlxorm.SessionOption) (err error)

func (*Client) DeletePipelineSource

func (client *Client) DeletePipelineSource(id string, pipelineSource *PipelineSource, ops ...mysqlxorm.SessionOption) error

func (*Client) GetPipelineSource

func (client *Client) GetPipelineSource(id string, ops ...mysqlxorm.SessionOption) (*PipelineSource, error)

func (*Client) GetPipelineSourceByUnique

func (client *Client) GetPipelineSourceByUnique(unique *PipelineSourceUnique, ops ...mysqlxorm.SessionOption) ([]PipelineSource, error)

func (*Client) GetUniqueSourceGroup

func (client *Client) GetUniqueSourceGroup(ops ...mysqlxorm.SessionOption) (uniqueSourceGroup []PipelineSourceUniqueGroupWithCount, err error)

func (*Client) ListPipelineSource

func (client *Client) ListPipelineSource(idList []string, ops ...mysqlxorm.SessionOption) ([]PipelineSource, error)

func (*Client) ListPipelineSourceByRemote

func (client *Client) ListPipelineSourceByRemote(remote string, ops ...mysqlxorm.SessionOption) ([]PipelineSource, error)

func (*Client) UpdatePipelineSource

func (client *Client) UpdatePipelineSource(id string, pipelineSource *PipelineSource, ops ...mysqlxorm.SessionOption) error

type PipelineSource

type PipelineSource struct {
	ID          string `json:"id" xorm:"pk"`
	SourceType  string `json:"sourceType"`
	Remote      string `json:"remote"`
	Ref         string `json:"ref"`
	Path        string `json:"path"`
	Name        string `json:"name"`
	PipelineYml string `json:"pipelineYml"`

	VersionLock   uint64    `json:"versionLock" xorm:"version_lock version"`
	SoftDeletedAt uint64    `json:"softDeletedAt"`
	CreatedAt     time.Time `json:"timeCreated,omitempty" xorm:"created_at created"`
	UpdatedAt     time.Time `json:"timeUpdated,omitempty" xorm:"updated_at updated"`
}

func (*PipelineSource) Convert

func (p *PipelineSource) Convert() *pb.PipelineSource

func (PipelineSource) TableName

func (PipelineSource) TableName() string

type PipelineSourceUnique

type PipelineSourceUnique struct {
	SourceType  string   `json:"sourceType"`
	Remote      string   `json:"remote"`
	Ref         string   `json:"ref"`
	Path        string   `json:"path"`
	Name        string   `json:"name"`
	IDList      []string `json:"idList"`
	VersionLock uint64   `json:"versionLock" xorm:"version_lock version"`
}

type PipelineSourceUniqueGroupWithCount

type PipelineSourceUniqueGroupWithCount struct {
	SourceType string `json:"sourceType"`
	Remote     string `json:"remote"`
	Ref        string `json:"ref"`
	Path       string `json:"path"`
	Name       string `json:"name"`
	Count      int    `json:"count"`
}