core

Documentation

Index

• Constants
• func GetManifestBodyCheckSum(imageName string) (uint32, error)
• func NSImages(op *SyncOption) ([]string, error)
• func Run(opt *SyncOption)
• func Sync(opt *SyncOption) error
• type CheckSumer
  • func NewBolt(db *bolt.DB) CheckSumer
• type Image
  • func (img *Image) Key() string
  • func (img *Image) String() string
• type Images
  • func ImageNames(opt *SyncOption) (Images, error)
  • func SyncImages(imgs Images, opt *SyncOption) Images
  • func (imgs Images) Len() int
  • func (imgs Images) Less(i, j int) bool
  • func (imgs Images) Swap(i, j int)
• type SyncOption
  • func (s *SyncOption) PreRun(cmd *cobra.Command, args []string) error
  • func (s *SyncOption) Verify() error
• type TagsOption

Constants

const (
	DefaultCtxTimeout = 5 * time.Minute
	DefaultLimit      = 20
)

const (
	DefaultHTTPTimeout = 15 * time.Second
)

Functions

func GetManifestBodyCheckSum

func GetManifestBodyCheckSum(imageName string) (uint32, error)

crc32 hash and err

func NSImages

func NSImages(op *SyncOption) ([]string, error)

baseName，不是full name

func Run

func Run(opt *SyncOption)

func Sync

func Sync(opt *SyncOption) error

Types

type CheckSumer

type CheckSumer interface {
	CreatBucket(string) error
	Diff(string, uint32) (bool, error)
	Save(string, uint32) error
}

func NewBolt

func NewBolt(db *bolt.DB) CheckSumer

type Image

type Image struct {
	Name string // basename
	Tag  string

	Success  bool
	CacheHit bool
	Err      error
}

func (*Image) Key

func (img *Image) Key() string

used for bolt.db

func (*Image) String

func (img *Image) String() string

type Images

type Images []*Image

func ImageNames

func ImageNames(opt *SyncOption) (Images, error)

并发获取k8s.gcr.io/$imgName:tag写入chan

func SyncImages

func SyncImages(imgs Images, opt *SyncOption) Images

func (Images) Len

func (imgs Images) Len() int

func (Images) Less

func (imgs Images) Less(i, j int) bool

func (Images) Swap

func (imgs Images) Swap(i, j int)

type SyncOption

type SyncOption struct {
	Auth          auth
	CmdTimeout    time.Duration // command timeout
	SingleTimeout time.Duration // Sync single image timeout
	LiveInterval  time.Duration
	LoginRetry    uint8
	Limit         int // Images sync process limit
	PushRepo      string
	PushNS        string
	QueryLimit    int // Query Gcr images limit
	Retry         int
	RetryInterval time.Duration
	Report        bool // Report sync result
	Ctx           context.Context
	CheckSumer
	Closer     func() error
	DbFile     string
	AdditionNS []string
}

func (*SyncOption) PreRun

func (s *SyncOption) PreRun(cmd *cobra.Command, args []string) error

func (*SyncOption) Verify

func (s *SyncOption) Verify() error

type TagsOption

type TagsOption struct {
	Timeout time.Duration
	// contains filtered or unexported fields
}