subscription

Documentation

Index

• type ClearWorkdirHandler
• type CommitFilesHandler
• type ConfigureRepositoryVersionsHandler
• type DumpConfigToFilesHandler
• type GetRepositoryAuthorsHandler
• type GetRepositoryHistoryHandler
• type MoveToWorkdirHandler
• type Plugin
• type ReadVersionFileHandler
• type SubscribeHandler
• type SubscribeManager
  • func NewSubscribeManager() *SubscribeManager
  • func (sm *SubscribeManager) Count() int
  • func (sm *SubscribeManager) Subscribe(sub Subscriber)
• type SyncProcessHandler
• type SyncVersionHandler
• type UpdateCfgHandler
• type WriteVersionFileHandler

Types

type ClearWorkdirHandler

type ClearWorkdirHandler interface {
	SubscribeHandler

	Subscribe(sub ClearWorkdirSubscriber)

	Before(v8end V8Endpoint, workdir, temp string) error
	On(v8end V8Endpoint, workdir, temp string, stdHandler *bool) error
	After(v8end V8Endpoint, workdir, temp string) error
}

type CommitFilesHandler

type CommitFilesHandler interface {
	SubscribeHandler

	Subscribe(sub CommitFilesSubscriber)

	Before(v8end V8Endpoint, workdir string, author types.RepositoryAuthor, when time.Time, comment string) error
	On(v8end V8Endpoint, workdir string, author types.RepositoryAuthor, when *time.Time, comment *string, stdHandler *bool) error
	After(v8end V8Endpoint, workdir string, author types.RepositoryAuthor, when time.Time, comment string) error
}

type ConfigureRepositoryVersionsHandler

type ConfigureRepositoryVersionsHandler interface {
	SubscribeHandler
	Subscribe(sub ConfigureRepositoryVersionsSubscriber)
	On(v8end V8Endpoint, versions *types.RepositoryVersionsList, NCurrent, NNext, NMax *int) error
}

type DumpConfigToFilesHandler

type DumpConfigToFilesHandler interface {
	SubscribeHandler

	Subscribe(sub DumpConfigToFilesSubscriber)
	Before(v8end V8Endpoint, workdir string, temp string, number int, update *bool) error
	On(v8end V8Endpoint, workdir string, temp string, number int, update *bool, stdHandler *bool) error
	After(v8end V8Endpoint, workdir string, temp string, number int, update bool) error
}

type GetRepositoryAuthorsHandler

type GetRepositoryAuthorsHandler interface {
	SubscribeHandler
	Subscribe(sub GetRepositoryAuthorsSubscriber)

	Before(v8end V8Endpoint, workdir string, filename string) error
	On(v8end V8Endpoint, workdir string, filename string, stdHandler *bool) (map[string]types.RepositoryAuthor, error)
	After(v8end V8Endpoint, workdir string, authors *types.RepositoryAuthorsList) error
}

type GetRepositoryHistoryHandler

type GetRepositoryHistoryHandler interface {
	SubscribeHandler
	Subscribe(sub GetRepositoryHistorySubscriber)

	Before(v8end V8Endpoint, dir string, NBegin int) error
	On(v8end V8Endpoint, dir string, NBegin int, stdHandler *bool) ([]types.RepositoryVersion, error)
	After(v8end V8Endpoint, dir string, NBegin int, rv *types.RepositoryVersionsList) error
}

type MoveToWorkdirHandler

type MoveToWorkdirHandler interface {
	SubscribeHandler

	Subscribe(sub MoveToWorkdirSubscriber)

	Before(v8end V8Endpoint, workdir, temp string) error
	On(v8end V8Endpoint, workdir, temp string, stdHandler *bool) error
	After(v8end V8Endpoint, workdir, temp string) error
}

type Plugin

type Plugin interface {
	Subscribe() Subscriber
}

type ReadVersionFileHandler

type ReadVersionFileHandler interface {
	SubscribeHandler

	Subscribe(sub ReadVersionFileSubscriber)

	Before(v8end V8Endpoint, workdir, filename string) error
	On(v8end V8Endpoint, workdir, filename string, stdHandler *bool) (int, error)
	After(v8end V8Endpoint, workdir, filename string, number *int) error
}

type SubscribeHandler

type SubscribeHandler interface {
	Count() int
}

type SubscribeManager

type SubscribeManager struct {
	UpdateCfg                   UpdateCfgHandler
	DumpConfigToFiles           DumpConfigToFilesHandler
	GetRepositoryHistory        GetRepositoryHistoryHandler
	ConfigureRepositoryVersions ConfigureRepositoryVersionsHandler
	GetRepositoryAuthors        GetRepositoryAuthorsHandler
	SyncVersion                 SyncVersionHandler
	SyncProcess                 SyncProcessHandler
	CommitFiles                 CommitFilesHandler
	ReadVersionFile             ReadVersionFileHandler
	WriteVersionFile            WriteVersionFileHandler
	ClearWorkdir                ClearWorkdirHandler
	MoveToWorkdir               MoveToWorkdirHandler
	// contains filtered or unexported fields
}

func NewSubscribeManager

func NewSubscribeManager() *SubscribeManager

func (*SubscribeManager) Count

func (sm *SubscribeManager) Count() int

func (*SubscribeManager) Subscribe

func (sm *SubscribeManager) Subscribe(sub Subscriber)

type SyncProcessHandler

type SyncProcessHandler interface {
	SubscribeHandler
	Subscribe(sub SyncProcessSubscriber)

	Start(v8end V8Endpoint, dir string)
	Finish(v8end V8Endpoint, dir string, err *error)
}

type SyncVersionHandler

type SyncVersionHandler interface {
	SubscribeHandler
	Subscribe(sub SyncVersionSubscriber)

	Start(v8end V8Endpoint, dir, temp string, number int)
	Finish(v8end V8Endpoint, dir, temp string, number int, err *error)
}

type UpdateCfgHandler

type UpdateCfgHandler interface {
	SubscribeHandler
	Subscribe(sub UpdateCfgSubscriber)
	Before(v8end V8Endpoint, workdir string, number int) error
	On(v8end V8Endpoint, workdir string, number int, standartHandler *bool) error
	After(v8end V8Endpoint, workdir string, number int) error

	BeforeFn(v8end V8Endpoint, workdir string, number int) func() error
}

type WriteVersionFileHandler

type WriteVersionFileHandler interface {
	SubscribeHandler

	Subscribe(sub WriteVersionFileSubscriber)

	Before(v8end V8Endpoint, workdir string, number int, filename string) error
	On(v8end V8Endpoint, workdir string, number int, filename string, stdHandler *bool) error
	After(v8end V8Endpoint, workdir string, number int, filename string) error
}