depends

Documentation

Index

• type DataContainer
  • func NewDataContainer() *DataContainer
  • func (dc *DataContainer) Get(key string) (value interface{})
  • func (dc *DataContainer) Set(key string, value interface{})
• type Depends
  • func NewDepends(timeout time.Duration) *Depends
  • func (me *Depends) AddDepend(service IService, serviceDepends []IService) error
  • func (me *Depends) Execute(ctx context.Context)
  • func (me *Depends) Register(service IService) error
• type IService
• type ServiceA
  • func NewServiceA() *ServiceA
  • func (s *ServiceA) Decode(receiver interface{}) error
  • func (s *ServiceA) Name() string
  • func (s *ServiceA) Run(ctx context.Context, dc *DataContainer) error
• type ServiceAData
• type ServiceB
  • func NewServiceB() *ServiceB
  • func (s *ServiceB) Decode(receiver interface{}) error
  • func (s *ServiceB) Name() string
  • func (s *ServiceB) Run(ctx context.Context, dc *DataContainer) error
• type ServiceBData
• type ServiceC
  • func NewServiceC() *ServiceC
  • func (s *ServiceC) Decode(receiver interface{}) error
  • func (s *ServiceC) Name() string
  • func (s *ServiceC) Run(ctx context.Context, dc *DataContainer) error
• type ServiceCData

Types

type DataContainer

type DataContainer struct {
	// contains filtered or unexported fields
}

func NewDataContainer

func NewDataContainer() *DataContainer

func (*DataContainer) Get

func (dc *DataContainer) Get(key string) (value interface{})

func (*DataContainer) Set

func (dc *DataContainer) Set(key string, value interface{})

type Depends

type Depends struct {
	// contains filtered or unexported fields
}

func NewDepends

func NewDepends(timeout time.Duration) *Depends

func (*Depends) AddDepend

func (me *Depends) AddDepend(service IService, serviceDepends []IService) error

添加依赖关系

func (*Depends) Execute

func (me *Depends) Execute(ctx context.Context)

执行

func (*Depends) Register

func (me *Depends) Register(service IService) error

注册服务

type IService

type IService interface {
	Name() string
	Run(ctx context.Context, dc *DataContainer) error
	Decode(receiver interface{}) error
}

type ServiceA

type ServiceA struct {
	// contains filtered or unexported fields
}

func NewServiceA

func NewServiceA() *ServiceA

func (*ServiceA) Decode

func (s *ServiceA) Decode(receiver interface{}) error

func (*ServiceA) Name

func (s *ServiceA) Name() string

func (*ServiceA) Run

func (s *ServiceA) Run(ctx context.Context, dc *DataContainer) error

type ServiceAData

type ServiceAData struct {
	Message string
	Query   string
}

type ServiceB

type ServiceB struct {
	// contains filtered or unexported fields
}

func NewServiceB

func NewServiceB() *ServiceB

func (*ServiceB) Decode

func (s *ServiceB) Decode(receiver interface{}) error

func (*ServiceB) Name

func (s *ServiceB) Name() string

func (*ServiceB) Run

func (s *ServiceB) Run(ctx context.Context, dc *DataContainer) error

type ServiceBData

type ServiceBData struct {
	Message string
	Query   string
}

type ServiceC

type ServiceC struct {
	// contains filtered or unexported fields
}

func NewServiceC

func NewServiceC() *ServiceC

func (*ServiceC) Decode

func (s *ServiceC) Decode(receiver interface{}) error

func (*ServiceC) Name

func (s *ServiceC) Name() string

func (*ServiceC) Run

func (s *ServiceC) Run(ctx context.Context, dc *DataContainer) error

type ServiceCData

type ServiceCData struct {
	Message string
	Query   string
}