sync

Documentation

Index

• Constants
• Variables
• func DownloadConfig(cli *http.Client, objectPath string, cfg *specv1.Configuration) error
• func FilterConfig(cfg *specv1.Configuration)
• func PrepareApp(hostPath, objectPath string, app *specv1.Application, ...) error
• type Sync
  • func NewSync(cfg config.Config, store *bh.Store, nod node.Node) (Sync, error)
• type UploadObjectFunc
• type WriteCounter
  • func (wc *WriteCounter) Write(p []byte) (int, error)

Constants

const (
	EnvKeyNodeName      = "BAETYL_NODE_NAME"
	EnvKeyNodeNamespace = "BAETYL_NODE_NAMESPACE"

	TopicUpside   = "upside"
	TopicDownside = "downside"

	TopicDM = "dm"

	BaetylHookUploadObject = "baetyl_upload_object"
)

Variables

var Hooks = map[string]interface{}{}

Functions

func DownloadConfig

func DownloadConfig(cli *http.Client, objectPath string, cfg *specv1.Configuration) error

func FilterConfig

func FilterConfig(cfg *specv1.Configuration)

func PrepareApp

func PrepareApp(hostPath, objectPath string, app *specv1.Application, cfgs map[string]specv1.Configuration) error

TODO: move to the right place

Types

type Sync

type Sync interface {
	Start()
	Close()
	Report(r v1.Report) (v1.Desire, error)
	SyncResource(v1.AppInfo) error
	SyncApps(infos []v1.AppInfo) (map[string]v1.Application, error)
}

func NewSync

func NewSync(cfg config.Config, store *bh.Store, nod node.Node) (Sync, error)

NewSync create a new sync

type UploadObjectFunc

type UploadObjectFunc func(dir, file, md5, unpack string) error

type WriteCounter

type WriteCounter struct {
	Interval time.Duration
	Printer  func(uint64)
	// contains filtered or unexported fields
}

func (*WriteCounter) Write

func (wc *WriteCounter) Write(p []byte) (int, error)