workflow

package module

v1.3.6 Latest Latest Go to latest Published: Sep 15, 2023 License: BSD-3-Clause Imports: 11 Imported by: 0

Details

Hybrid workflow, general serverless, data processing, file processing

This section is empty.

This section is empty.

This section is empty.

type ExcelMetadata struct {
	Name  string   `msgpack:"name"`
	Parts []string `msgpack:"parts"`
}

type File struct {
	Cos *cos.Client
}

func (x *File) Excel(ctx context.Context, name string, sheets typ.ExcelSheets) (err error)

type Option func(x *Workflow)

func SetJetStream(v nats.JetStreamContext) Option

func SetNamespace(v string) Option

func SetNats(v *nats.Conn) Option

type Schedule struct {
	Namespace string
	Node      string
	Nats      *nats.Conn
	KeyValue  nats.KeyValue
}

func (x *Schedule) Get(key string) (option typ.ScheduleOption, err error)

func (x *Schedule) Lists() (keys []string, err error)

func (x *Schedule) Ping() (result bool, err error)

func (x *Schedule) Remove(key string) (err error)

func (x *Schedule) Set(key string, option typ.ScheduleOption) (err error)

func (x *Schedule) Status(key string, value bool) (err error)

type Workflow struct {
	Namespace string
	Nats      *nats.Conn
	JetStream nats.JetStreamContext
}

func New(options ...Option) *Workflow

func (x *Workflow) NewFile(address string, id string, key string) (f *File, err error)

func (x *Workflow) NewSchedule(node string) (schedule *Schedule, err error)