flows

Sep 6, 2024

Changes in this version

type StepOption

+ func WithState(state flows.Flow_Step_State) StepOption

Sep 5, 2024

Changes in this version

+ const FlowHeaderKey

Aug 19, 2024

Changes in this version

type Flow

+ func (f *Flow) Steps() *alUtils.OrderedMap[string, *Step]

+ type StepOption func(*StepOptions)

+ func WithDescription(description string) StepOption

+ func WithExistingId() StepOption

+ func WithTitle(title string) StepOption

+ type StepOptions struct

Aug 13, 2024

Changes in this version

+ var ParentIdRegex = regexp.MustCompile(`^([a-z0-9]+)-([^-]+)$`)

+ var StepIdRegex = regexp.MustCompile(`^[^-]+$`)

Aug 9, 2024

Changes in this version

+ const DefaultTopic

+ const FlowParentHeaderKey

+ type Client struct

+ func NewClient(project string, opts ...Option) (*Client, error)

+ func (c *Client) NewFlow(ctx context.Context) (*Flow, context.Context, error)

+ type Flow struct

+ func (f *Flow) NewStep(id string, title string) *Step

+ func (f *Flow) Publish() error

+ func (f *Flow) WithParentId(parentId string) *Flow

+ func (f *Flow) WithSource(source string) *Flow

+ type Option func(*Options)

+ func WithAwaitPublish() Option

+ func WithTopic(topic string) Option

+ type Options struct

+ AwaitPublish bool

+ Topic string

+ type Step struct

+ func (s *Step) AwaitingInput() *Step

+ func (s *Step) Cancelled() *Step

+ func (s *Step) Done() *Step

+ func (s *Step) Failed(err error) *Step

+ func (s *Step) InProgress() *Step

+ func (s *Step) Publish() error

+ func (s *Step) Queued() *Step

+ func (s *Step) WithDescription(description string) *Step

+ func (s *Step) WithTitle(title string) *Step