diagnosticv1alpha1

type AllDiagnostics struct {
	OauthTokenMetadata *GetOAuthTokenMetadataResponse `protobuf:"bytes,1,opt,name=oauth_token_metadata,json=oauthTokenMetadata,proto3" json:"oauth_token_metadata,omitempty"`
	// contains filtered or unexported fields
}

type AttemptError struct {

	// At is the time at which the error occurred.
	At *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=at,proto3" json:"at,omitempty"`
	// Attempt is the attempt number on which the error occurred (maps to
	// Attempt on a job row).
	Attempt int64 `protobuf:"varint,2,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// Error contains the stringified error of an error returned from a job or a
	// panic value in case of a panic.
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// Trace contains a stack trace from a job that panicked. The trace is
	// produced by invoking `debug.Trace()`.
	Trace string `protobuf:"bytes,4,opt,name=trace,proto3" json:"trace,omitempty"`
	// contains filtered or unexported fields
}

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

type GetOAuthTokenMetadataResponse struct {
	Tokens []*OAuthTokenMetadata `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
	// contains filtered or unexported fields
}

type Job struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Attempt is the attempt number of the job. Jobs are inserted at 0, the
	// number is incremented to 1 the first time work its worked, and may
	// increment further if it's either snoozed or errors.
	Attempt int64 `protobuf:"varint,2,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// AttemptedAt is the time that the job was last worked. Starts out as `nil`
	// on a new insert.
	AttemptedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=attempted_at,json=attemptedAt,proto3" json:"attempted_at,omitempty"`
	// AttemptedBy is the set of client IDs that have worked this job.
	AttemptedBy []string `protobuf:"bytes,4,rep,name=attempted_by,json=attemptedBy,proto3" json:"attempted_by,omitempty"`
	// CreatedAt is when the job record was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// EncodedArgs is the job's JobArgs encoded as JSON.
	EncodedArgs []byte `protobuf:"bytes,6,opt,name=encoded_args,json=encodedArgs,proto3" json:"encoded_args,omitempty"`
	// Errors is a set of errors that occurred when the job was worked, one for
	// each attempt. Ordered from earliest error to the latest error.
	Errors []*AttemptError `protobuf:"bytes,7,rep,name=errors,proto3" json:"errors,omitempty"`
	// FinalizedAt is the time at which the job was "finalized", meaning it was
	// either completed successfully or errored for the last time such that
	// it'll no longer be retried.
	FinalizedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=finalized_at,json=finalizedAt,proto3" json:"finalized_at,omitempty"`
	// Kind uniquely identifies the type of job and instructs which worker
	// should work it. It is set at insertion time via `Kind()` on the
	// `JobArgs`.
	Kind string `protobuf:"bytes,9,opt,name=kind,proto3" json:"kind,omitempty"`
	// MaxAttempts is the maximum number of attempts that the job will be tried
	// before it errors for the last time and will no longer be worked.
	//
	// Extracted (in order of precedence) from job-specific InsertOpts
	// on Insert, from the worker level InsertOpts from JobArgsWithInsertOpts,
	// or from a client's default value.
	MaxAttempts int64 `protobuf:"varint,10,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	// Metadata is a field for storing arbitrary metadata on a job. It should
	// always be a valid JSON object payload, and users should not overwrite or
	// remove anything stored in this field by River.
	Metadata []byte `protobuf:"bytes,11,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Priority is the priority of the job, with 1 being the highest priority and
	// 4 being the lowest. When fetching available jobs to work, the highest
	// priority jobs will always be fetched before any lower priority jobs are
	// fetched. Note that if your workers are swamped with more high-priority jobs
	// then they can handle, lower priority jobs may not be fetched.
	Priority int64 `protobuf:"varint,12,opt,name=priority,proto3" json:"priority,omitempty"`
	// Queue is the name of the queue where the job will be worked. Queues can
	// be configured independently and be used to isolate jobs.
	//
	// Extracted from either specific InsertOpts on Insert, or InsertOpts from
	// JobArgsWithInsertOpts, or a client's default value.
	Queue string `protobuf:"bytes,13,opt,name=queue,proto3" json:"queue,omitempty"`
	// ScheduledAt is when the job is scheduled to become available to be
	// worked. Jobs default to running immediately, but may be scheduled
	// for the future when they're inserted. They may also be scheduled for
	// later because they were snoozed or because they errored and have
	// additional retry attempts remaining.
	ScheduledAt *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	// State is the state of job like `available` or `completed`. Jobs are
	// `available` when they're first inserted.
	State string `protobuf:"bytes,15,opt,name=state,proto3" json:"state,omitempty"`
	// Tags are an arbitrary list of keywords to add to the job. They have no
	// functional behavior and are meant entirely as a user-specified construct
	// to help group and categorize jobs.
	Tags []string `protobuf:"bytes,16,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

type JobState int32

type JobSummary struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Kind        string                 `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Errors      []*RiverError          `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	State       string                 `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	LastRun     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_run,json=lastRun,proto3" json:"last_run,omitempty"`
	TimeElapsed *durationpb.Duration   `protobuf:"bytes,6,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"`
	// contains filtered or unexported fields
}

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

type ListBackgroundJobKindSummaryResponse struct {
	Jobs []*JobSummary `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

type ListBackgroundJobsRequest struct {

	// Optionally filter jobs by kind, supplying an empty list will return jobs for all kinds
	Kinds []string `protobuf:"bytes,1,rep,name=kinds,proto3" json:"kinds,omitempty"`
	// by default requests will return upp to 100 jobs, set this between 1 and 10000 to retrieve more jobs
	Count *int64 `protobuf:"varint,2,opt,name=count,proto3,oneof" json:"count,omitempty"`
	// The job state to filter for
	State *JobState `protobuf:"varint,3,opt,name=state,proto3,enum=commonfate.control.diagnostic.v1alpha1.JobState,oneof" json:"state,omitempty"`
	// contains filtered or unexported fields
}

type ListBackgroundJobsResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

type OAuthTokenMetadata struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	AppName   string                 `protobuf:"bytes,2,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

type RiverError struct {
	OccuredAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=occured_at,json=occuredAt,proto3" json:"occured_at,omitempty"`
	Attempt   int64                  `protobuf:"varint,2,opt,name=attempt,proto3" json:"attempt,omitempty"`
	Error     string                 `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Trace     string                 `protobuf:"bytes,4,opt,name=trace,proto3" json:"trace,omitempty"`
	// contains filtered or unexported fields
}