gateway

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

type Config struct {
	// Service name registered with the gateway
	Name string `json:"name"`

	// Log defines a custom log configuration for the gateway.
	Log *zeroconf.Log `json:"log"`

	// WorkerCount
	WorkerCount int `json:"worker_count"`

	// NATS configuration used to connect to the gateway.
	NATS *natsconf.Config `json:"nats"`

	// Silo configuration options mainly for file upload.
	Silo *Silo `json:"silo"`
}

type Configuration interface {
	Init() error // Prepare
	// contains filtered or unexported methods
}

type CreateFile struct {
	Id          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	JobId       string            `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // for request tracing
	SiloEntryId string            `protobuf:"bytes,3,opt,name=silo_entry_id,json=siloEntryId,proto3" json:"silo_entry_id,omitempty"`
	Name        string            `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Desc        string            `protobuf:"bytes,5,opt,name=desc,proto3" json:"desc,omitempty"`
	Embeddable  bool              `protobuf:"varint,10,opt,name=embeddable,proto3" json:"embeddable,omitempty"` // can this file be embedded?
	Private     bool              `protobuf:"varint,11,opt,name=private,proto3" json:"private,omitempty"`       // do not generate public links
	Sha256      string            `protobuf:"bytes,6,opt,name=sha256,proto3" json:"sha256,omitempty"`
	Mime        string            `protobuf:"bytes,7,opt,name=mime,proto3" json:"mime,omitempty"`
	Size        int32             `protobuf:"varint,8,opt,name=size,proto3" json:"size,omitempty"`
	Meta        map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Error struct {
	Code    ErrorCode `protobuf:"varint,1,opt,name=code,proto3,enum=invopop.provider.v1.ErrorCode" json:"code,omitempty"`
	Message string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ErrorCode int32

type Fault struct {
	Provider string   `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
	Code     string   `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Paths    []string `protobuf:"bytes,5,rep,name=paths,proto3" json:"paths,omitempty"`
	Message  string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Fields   []byte   `protobuf:"bytes,4,opt,name=fields,proto3" json:"fields,omitempty"` // Deprecated: JSON encoded list of validation errors
	// contains filtered or unexported fields
}

type File struct {
	Id          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	SiloEntryId string            `protobuf:"bytes,7,opt,name=silo_entry_id,json=siloEntryId,proto3" json:"silo_entry_id,omitempty"`
	Hash        string            `protobuf:"bytes,8,opt,name=hash,proto3" json:"hash,omitempty"`
	Name        string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Desc        string            `protobuf:"bytes,9,opt,name=desc,proto3" json:"desc,omitempty"`
	Mime        string            `protobuf:"bytes,3,opt,name=mime,proto3" json:"mime,omitempty"`
	PublicUrl   string            `protobuf:"bytes,4,opt,name=public_url,json=publicUrl,proto3" json:"public_url,omitempty"`
	Meta        map[string]string ``                                                                            /* 149-byte string literal not displayed */
	Uploaded    bool              `protobuf:"varint,6,opt,name=uploaded,proto3" json:"uploaded,omitempty"`      // True if the file data has been uploaded.
	Embeddable  bool              `protobuf:"varint,10,opt,name=embeddable,proto3" json:"embeddable,omitempty"` // Can this file be embedded inside others, like PDFs?
	Private     bool              `protobuf:"varint,11,opt,name=private,proto3" json:"private,omitempty"`       // Should this file not have public links?
	// contains filtered or unexported fields
}

type FileResponse struct {
	File *File  `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	Err  *Error `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

type Meta struct {
	Src     string `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Key     string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Ref     string `protobuf:"bytes,4,opt,name=ref,proto3" json:"ref,omitempty"`
	LinkUrl string `protobuf:"bytes,5,opt,name=link_url,json=linkUrl,proto3" json:"link_url,omitempty"`
	Value   []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Option func(gw *Client)

type Silo struct {
	PublicBaseURL string `json:"public_base_url"`
}

type Task struct {

	// Basic details
	Id          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedTs   int64             `protobuf:"varint,19,opt,name=created_ts,json=createdTs,proto3" json:"created_ts,omitempty"` // unix time when the intent was originally created
	JobId       string            `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobKey      string            `protobuf:"bytes,17,opt,name=job_key,json=jobKey,proto3" json:"job_key,omitempty"`
	SiloEntryId string            `protobuf:"bytes,3,opt,name=silo_entry_id,json=siloEntryId,proto3" json:"silo_entry_id,omitempty"` // was previously envelope_id
	OwnerId     string            `protobuf:"bytes,9,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`               // May be used for authentication
	Args        map[string]string ``                                                                                                 /* 150-byte string literal not displayed */
	Ref         string            `protobuf:"bytes,10,opt,name=ref,proto3" json:"ref,omitempty"`                                     // If provided in a previous request, will be here too
	Action      string            `protobuf:"bytes,12,opt,name=action,proto3" json:"action,omitempty"`                               // Action to be performed by the provider.
	Sandbox     bool              `protobuf:"varint,16,opt,name=sandbox,proto3" json:"sandbox,omitempty"`                            // If true, execute in sandbox environment.
	// Token proves that the request came from the gateway and can be used
	// by the provider to make additional requests to the gateway on behalf
	// of the end-user.
	Token string `protobuf:"bytes,11,opt,name=token,proto3" json:"token,omitempty"`
	// Quick access to data
	State             string `protobuf:"bytes,13,opt,name=state,proto3" json:"state,omitempty"` // state of the silo entry
	Envelope          []byte `protobuf:"bytes,4,opt,name=envelope,proto3" json:"envelope,omitempty"`
	Config            []byte `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	EnvelopePublicUrl string `protobuf:"bytes,7,opt,name=envelope_public_url,json=envelopePublicUrl,proto3" json:"envelope_public_url,omitempty"`
	// Array of faults copied from the job which may be useful for reporting.
	Faults []*Fault `protobuf:"bytes,14,rep,name=faults,proto3" json:"faults,omitempty"`
	// Rerefence to any existing attachments
	Files []*File `protobuf:"bytes,6,rep,name=files,proto3" json:"files,omitempty"`
	// Shared meta rows, if any, associated with the silo entry.
	Meta []*Meta `protobuf:"bytes,15,rep,name=meta,proto3" json:"meta,omitempty"`
	// Tracking timestamp, issued by the gateway service. Includes nano seconds.
	Ts float64 `protobuf:"fixed64,8,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

type TaskHandler func(ctx context.Context, task *Task) *TaskResult

type TaskPoke struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Task (Intent) ID
	JobId   string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Ref     string `protobuf:"bytes,3,opt,name=ref,proto3" json:"ref,omitempty"` // If id and job_id are not available
	Code    string `protobuf:"bytes,4,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type TaskPokeResponse struct {
	Err *Error `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

type TaskResult struct {
	Status TaskStatus `protobuf:"varint,1,opt,name=status,proto3,enum=invopop.provider.v1.TaskStatus" json:"status,omitempty"`
	// optional provider response code
	Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	// Additional arguments that the task would like to supply to -next- steps
	Args map[string]string `` /* 150-byte string literal not displayed */
	// human response message
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// fields contains a JSON encoded set of nested field validation errors defined
	// by the `gobl.FieldErrors` type.
	Fields []byte `protobuf:"bytes,15,opt,name=fields,proto3" json:"fields,omitempty"`
	// reference that can be used to identify the job later such
	// as in a poke request.
	Ref string `protobuf:"bytes,11,opt,name=ref,proto3" json:"ref,omitempty"`
	// sign when true, will ensure the envelope is signed
	Sign bool `protobuf:"varint,12,opt,name=sign,proto3" json:"sign,omitempty"`
	// envelope data either complete or patched according to content_type
	Data []byte `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"`
	// Content type of data to send to the silo
	ContentType string `protobuf:"bytes,10,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// For QUEUED or ERR response, how long to wait to try again (optional).
	RetryIn int32 `protobuf:"varint,6,opt,name=retry_in,json=retryIn,proto3" json:"retry_in,omitempty"`
	// Optional Silo Entry ID to be used when a new silo entry was created
	// by this task, and it should be used for all subsequent actions in
	// the workflow. If data is also included, the silo entry will be created.
	SiloEntryId *string `protobuf:"bytes,13,opt,name=silo_entry_id,json=siloEntryId,proto3,oneof" json:"silo_entry_id,omitempty"`
	// contains filtered or unexported fields
}

type TaskStatus int32