dataUpdate

Documentation

Index

• type DataUpdate
  • func NewDataUpdate(c conf.EventConf) (DataUpdate, error)
• type Handle
• type NatsClient
  • func (n *NatsClient) Subscribe(handle Handle) error
• type UpdateHandle

Types

type DataUpdate

type DataUpdate interface {
	Subscribe(handle Handle) error
}

func NewDataUpdate

func NewDataUpdate(c conf.EventConf) (DataUpdate, error)

type Handle

type Handle func(ctx context.Context) UpdateHandle

type NatsClient

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

func (*NatsClient) Subscribe

func (n *NatsClient) Subscribe(handle Handle) error

type UpdateHandle

type UpdateHandle interface {
	ProductSchemaUpdate(info *events.DeviceUpdateInfo) error
}