tutorial

Documentation

Index

• Constants
• Variables
• type Entry
  • func NewEntry(appID string) *Entry
  • func (e *Entry) AddProgress(ps []Progress)
  • func (e *Entry) Skip()
• type Progress
  • func ProgressFromString(s string) (Progress, bool)
• type Service
  • func (s *Service) DetectProgresses(resourceInTargetFs *resource.ResourceFile, data []byte) (out []Progress, err error)
  • func (s *Service) Get(appID string) (*Entry, error)
  • func (s *Service) OnUpdateResource(ctx context.Context, appID string, resourcesInAllFss []resource.ResourceFile, ...) (err error)
  • func (s *Service) RecordProgresses(appID string, ps []Progress) (err error)
  • func (s *Service) Skip(appID string) (err error)
• type Sink
  • func (s *Sink) ReceiveBlockingEvent(e *event.Event) error
  • func (s *Sink) ReceiveNonBlockingEvent(e *event.Event) error
• type Store
• type StoreImpl
  • func (s *StoreImpl) Get(appID string) (*Entry, error)
  • func (s *StoreImpl) Save(entry *Entry) error

Constants

const (
	ProgressAuthui            = "authui"
	ProgressCustomizeUI       = "customize_ui"
	ProgressCreateApplication = "create_application"
	ProgressSSO               = "sso"
	ProgressInvite            = "invite"
)

Variables

var DependencySet = wire.NewSet(
	wire.Struct(new(Service), "*"),
	wire.Struct(new(StoreImpl), "*"),
	wire.Struct(new(Sink), "*"),
	wire.Bind(new(Store), new(*StoreImpl)),
)

Types

type Entry

type Entry struct {
	AppID string
	Data  map[string]interface{}
}

func NewEntry

func NewEntry(appID string) *Entry

func (*Entry) AddProgress

func (e *Entry) AddProgress(ps []Progress)

func (*Entry) Skip

func (e *Entry) Skip()

type Progress

type Progress string

func ProgressFromString

func ProgressFromString(s string) (Progress, bool)

type Service

type Service struct {
	Store Store
}

func (*Service) DetectProgresses

func (s *Service) DetectProgresses(resourceInTargetFs *resource.ResourceFile, data []byte) (out []Progress, err error)

func (*Service) Get

func (s *Service) Get(appID string) (*Entry, error)

func (*Service) OnUpdateResource

func (s *Service) OnUpdateResource(ctx context.Context, appID string, resourcesInAllFss []resource.ResourceFile, resourceInTargetFs *resource.ResourceFile, data []byte) (err error)

func (*Service) RecordProgresses

func (s *Service) RecordProgresses(appID string, ps []Progress) (err error)

func (*Service) Skip

func (s *Service) Skip(appID string) (err error)

type Sink

type Sink struct {
	AppID        config.AppID
	Service      *Service
	GlobalHandle *globaldb.Handle
}

func (*Sink) ReceiveBlockingEvent

func (s *Sink) ReceiveBlockingEvent(e *event.Event) error

func (*Sink) ReceiveNonBlockingEvent

func (s *Sink) ReceiveNonBlockingEvent(e *event.Event) error

type Store

type Store interface {
	Get(appID string) (*Entry, error)
	Save(entry *Entry) error
}

type StoreImpl

type StoreImpl struct {
	SQLBuilder  *globaldb.SQLBuilder
	SQLExecutor *globaldb.SQLExecutor
}

func (*StoreImpl) Get

func (s *StoreImpl) Get(appID string) (*Entry, error)

func (*StoreImpl) Save

func (s *StoreImpl) Save(entry *Entry) error