async

Documentation

Index

• type Config
  • func (c *Config) CreateJob(ctx context.Context, job *async.Job, notification *async.Notification) error
  • func (n *Config) DestinationURL(job *async.Job) string
  • func (c *Config) ErrorTTL() time.Duration
  • func (c *Config) Init(ctx context.Context, resource *view.Resource, mainView *view.View) error
  • func (c *Config) JobByID(ctx context.Context, jobID string) (*async.Job, error)
  • func (c *Config) JobByMatchKey(ctx context.Context, jobRef string) (*async.Job, error)
  • func (c *Config) Lock()
  • func (c *Config) TTL() time.Duration
  • func (c *Config) Unlock()
  • func (c *Config) UpdateJob(ctx context.Context, job *async.Job) error
• type Jobs
• type State
  • func (s *State) Init(ctx context.Context, res *view.Resource, mainView *view.View) error

Types

type Config

type Config struct {
	Jobs
	State
	WithCache            bool
	ExpiryTimeInSec      int
	ErrorExpiryTimeInSec int
	async.Notification
	// contains filtered or unexported fields
}

func (*Config) CreateJob

func (c *Config) CreateJob(ctx context.Context, job *async.Job, notification *async.Notification) error

func (*Config) DestinationURL

func (n *Config) DestinationURL(job *async.Job) string

func (*Config) ErrorTTL

func (c *Config) ErrorTTL() time.Duration

func (*Config) Init

func (c *Config) Init(ctx context.Context, resource *view.Resource, mainView *view.View) error

func (*Config) JobByID

func (c *Config) JobByID(ctx context.Context, jobID string) (*async.Job, error)

func (*Config) JobByMatchKey

func (c *Config) JobByMatchKey(ctx context.Context, jobRef string) (*async.Job, error)

func (*Config) Lock

func (c *Config) Lock()

func (*Config) TTL

func (c *Config) TTL() time.Duration

func (*Config) Unlock

func (c *Config) Unlock()

func (*Config) UpdateJob

func (c *Config) UpdateJob(ctx context.Context, job *async.Job) error

type Jobs

type Jobs struct {
	Connector *view.Connector
	Dataset   string
	// contains filtered or unexported fields
}

type State

type State struct {
	UserID      *state.Parameter
	UserEmail   *state.Parameter
	JobMatchKey *state.Parameter
}

State defines location for the followings

func (*State) Init

func (s *State) Init(ctx context.Context, res *view.Resource, mainView *view.View) error