gw

Documentation

Index

• Constants
• func Run(ctx context.Context, tr TaskRunner) error
• type Error
  • func (e Error) Error() string
• type Task
  • func (c *Task) Close() error
  • func (c *Task) Config() *config.Service
  • func (c *Task) Context() *taskcontext.Service
  • func (c *Task) Docker() *docker.Service
  • func (c *Task) JSONStore(name string) *jsonstore.Store
  • func (c *Task) KV() *kv.Service
  • func (c *Task) Lock() *lock.Service
  • func (c *Task) Log(ctx context.Context, format string, v ...interface{}) error
  • func (c *Task) Secret() *secret.Service
• type TaskRunner
• type TaskRunnerFunc
  • func (f TaskRunnerFunc) Run(ctx context.Context, ts *Task) (map[string]value.Value, error)

Constants

const (
	DefaultOrgName  = "Default"
	DefaultTeamName = "default"
	DefaultTeamID   = "00000000-0000-0000-0000-000000000000"
)

const (
	EnvGRPCAddress = "GRPC_ADDR"
	EnvMagicKey    = "GRPC_MAGIC_KEY"
	EnvMagicValue  = "d0c08ee0-a663-4a6b-ad5e-00a5fca1e5cf"
	EnvCAFile      = "GRPC_CA_CERT_FILE"
	EnvCertFile    = "GRPC_CLIENT_CERT_FILE"
	EnvKeyFile     = "GRPC_CLIENT_KEY_FILE"
	EnvOrgName     = "CONCORD_ORG_NAME"
	EnvProcessID   = "CONCORD_PROCESS_ID"
	EnvWorkingDir  = "CONCORD_WORKING_DIRECTORY"
)

const (
	ErrNoMagicKey = Error("no magic key provided")
	ErrNoGRPCAddr = Error("no grpc address provided")
)

Functions

func Run

func Run(ctx context.Context, tr TaskRunner) error

Run a function

Types

type Error

type Error string

func (Error) Error

func (e Error) Error() string

type Task

type Task struct {
	OrgName    string
	WorkingDir string
	ProcessID  string
	// contains filtered or unexported fields
}

func (*Task) Close

func (c *Task) Close() error

func (*Task) Config

func (c *Task) Config() *config.Service

Config returns a service for retrieving process configuration

func (*Task) Context

func (c *Task) Context() *taskcontext.Service

Context returns a service for interacting with the process context such as setting and getting variabes, and evaluating the results of Java Expressions in JEL 3.0

func (*Task) Docker

func (c *Task) Docker() *docker.Service

Docker returns a service for running Docker containers

func (*Task) JSONStore

func (c *Task) JSONStore(name string) *jsonstore.Store

JSONStore returns a jsonstore.Store for the given store name The store should already exist, otherwise operations will fail. This store should be in the current Org of the process.

func (*Task) KV

func (c *Task) KV() *kv.Service

KV returns a service for interacting with the project's key-value storage system

func (*Task) Lock

func (c *Task) Lock() *lock.Service

Lock returns a service for setting project-level locks

func (*Task) Log

func (c *Task) Log(ctx context.Context, format string, v ...interface{}) error

Log emits a log entry on the process.

func (*Task) Secret

func (c *Task) Secret() *secret.Service

Secret returns a service for manipulating secrets within the current Organization

type TaskRunner

type TaskRunner interface {
	Run(ctx context.Context, ts *Task) (map[string]value.Value, error)
}

type TaskRunnerFunc

type TaskRunnerFunc func(ctx context.Context, ts *Task) (map[string]value.Value, error)

func (TaskRunnerFunc) Run

func (f TaskRunnerFunc) Run(ctx context.Context, ts *Task) (map[string]value.Value, error)