adminpb

type ActiveJobRun struct {
	RunId   string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Job     string `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	Started string `protobuf:"bytes,3,opt,name=started,proto3" json:"started,omitempty"` // RFC3339
	// contains filtered or unexported fields
}

type AdminAPIClient interface {
	// Access / step-up.
	RequestAdmin(ctx context.Context, in *RequestAdminRequest, opts ...grpc.CallOption) (*RequestAdminResponse, error)
	Impersonate(ctx context.Context, in *ImpersonateRequest, opts ...grpc.CallOption) (*ImpersonateResponse, error)
	// Introspection (read-only).
	GetServerInfo(ctx context.Context, in *GetServerInfoRequest, opts ...grpc.CallOption) (*GetServerInfoResponse, error)
	GetHealth(ctx context.Context, in *GetHealthRequest, opts ...grpc.CallOption) (*GetHealthResponse, error)
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error)
	GetServiceConfig(ctx context.Context, in *GetServiceConfigRequest, opts ...grpc.CallOption) (*GetServiceConfigResponse, error)
	// Invocations (reads and writes via the Invokable channel).
	ListInvocations(ctx context.Context, in *ListInvocationsRequest, opts ...grpc.CallOption) (*ListInvocationsResponse, error)
	Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeResponse, error)
	InvokeStream(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (AdminAPI_InvokeStreamClient, error)
	// Jobs: methods for interacting with the background job framework.
	InspectJobs(ctx context.Context, in *InspectJobsRequest, opts ...grpc.CallOption) (*InspectJobsResponse, error)
	ListJobRuns(ctx context.Context, in *ListJobRunsRequest, opts ...grpc.CallOption) (*ListJobRunsResponse, error)
	GetJobRun(ctx context.Context, in *GetJobRunRequest, opts ...grpc.CallOption) (*JobRun, error)
	EnqueueJob(ctx context.Context, in *EnqueueJobRequest, opts ...grpc.CallOption) (*EnqueueJobResponse, error)
	TriggerJob(ctx context.Context, in *TriggerJobRequest, opts ...grpc.CallOption) (*TriggerJobResponse, error)
	CancelJobRun(ctx context.Context, in *CancelJobRunRequest, opts ...grpc.CallOption) (*JobRun, error)
	CancelPeriodicJob(ctx context.Context, in *CancelPeriodicJobRequest, opts ...grpc.CallOption) (*CancelPeriodicJobResponse, error)
}

type AdminAPIServer interface {
	// Access / step-up.
	RequestAdmin(context.Context, *RequestAdminRequest) (*RequestAdminResponse, error)
	Impersonate(context.Context, *ImpersonateRequest) (*ImpersonateResponse, error)
	// Introspection (read-only).
	GetServerInfo(context.Context, *GetServerInfoRequest) (*GetServerInfoResponse, error)
	GetHealth(context.Context, *GetHealthRequest) (*GetHealthResponse, error)
	ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
	GetServiceConfig(context.Context, *GetServiceConfigRequest) (*GetServiceConfigResponse, error)
	// Invocations (reads and writes via the Invokable channel).
	ListInvocations(context.Context, *ListInvocationsRequest) (*ListInvocationsResponse, error)
	Invoke(context.Context, *InvokeRequest) (*InvokeResponse, error)
	InvokeStream(*InvokeRequest, AdminAPI_InvokeStreamServer) error
	// Jobs: methods for interacting with the background job framework.
	InspectJobs(context.Context, *InspectJobsRequest) (*InspectJobsResponse, error)
	ListJobRuns(context.Context, *ListJobRunsRequest) (*ListJobRunsResponse, error)
	GetJobRun(context.Context, *GetJobRunRequest) (*JobRun, error)
	EnqueueJob(context.Context, *EnqueueJobRequest) (*EnqueueJobResponse, error)
	TriggerJob(context.Context, *TriggerJobRequest) (*TriggerJobResponse, error)
	CancelJobRun(context.Context, *CancelJobRunRequest) (*JobRun, error)
	CancelPeriodicJob(context.Context, *CancelPeriodicJobRequest) (*CancelPeriodicJobResponse, error)
	// contains filtered or unexported methods
}

type AdminAPI_InvokeStreamClient interface {
	Recv() (*InvokeStreamResponse, error)
	grpc.ClientStream
}

type AdminAPI_InvokeStreamServer interface {
	Send(*InvokeStreamResponse) error
	grpc.ServerStream
}

type ArgSpec struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Required    bool   `protobuf:"varint,3,opt,name=required,proto3" json:"required,omitempty"`
	// contains filtered or unexported fields
}

type CancelJobRunRequest struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

type CancelPeriodicJobRequest struct {
	Job string `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

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

type EnqueueJobRequest struct {
	Job    string            `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Params map[string]string ``                                                                /* 153-byte string literal not displayed */
	Owner  string            `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` // optional: attribute the run to a user
	// contains filtered or unexported fields
}

type EnqueueJobResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

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

type GetHealthResponse struct {
	Services []*ServiceHealth `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

type GetJobRunRequest struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

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

type GetServerInfoResponse struct {
	Info *ServerInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

type GetServiceConfigRequest struct {

	// service is a selector: a service name (every instance) or a node id
	// "host:port/service" (one instance).
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

type GetServiceConfigResponse struct {

	// results carries one entry per resolved instance.
	Results []*NodeResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type ImpersonateRequest struct {

	// user is a target selector: either a bare username or "claim:value" (claim
	// in mail|uid|username|gid|userid), matching the machine auth manager.
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// reason is recorded in the audit log.
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type ImpersonateResponse struct {

	// token is an ordinary user-scoped token for the target user (never
	// admin+user).
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

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

type InspectJobsResponse struct {

	// runners carries one entry per live jobs runner in the fleet.
	Runners []*JobRunnerInfo `protobuf:"bytes,1,rep,name=runners,proto3" json:"runners,omitempty"`
	// contains filtered or unexported fields
}

type InvocationSpec struct {
	Name        string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string     `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Args        []*ArgSpec `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// kind is readonly|mutating|dangerous, used for audit and gating.
	Kind string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	// streaming reports the invocation emits a stream of results (via
	// InvokeStream) rather than a single one (Invoke).
	Streaming bool `protobuf:"varint,5,opt,name=streaming,proto3" json:"streaming,omitempty"`
	// contains filtered or unexported fields
}

type InvokeRequest struct {

	// service is a selector: a service name (every instance) or a node id
	// "host:port/service" (one instance).
	Service    string            `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Invocation string            `protobuf:"bytes,2,opt,name=invocation,proto3" json:"invocation,omitempty"`
	Args       map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type InvokeResponse struct {
	Results []*NodeResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type InvokeStreamResponse struct {
	Node       string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	ResultJson string `protobuf:"bytes,2,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
	Error      string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type JobDefinition struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Kind     string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`         // "periodic" | "on-demand"
	Schedule string `protobuf:"bytes,3,opt,name=schedule,proto3" json:"schedule,omitempty"` // periodic only
	Scope    string `protobuf:"bytes,4,opt,name=scope,proto3" json:"scope,omitempty"`       // periodic only: "leader" | "all-nodes"
	Overlap  string `protobuf:"bytes,5,opt,name=overlap,proto3" json:"overlap,omitempty"`   // periodic only: "skip" | "allow"
	// contains filtered or unexported fields
}

type JobRun struct {
	RunId           string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Job             string `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	State           string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` // queued|running|succeeded|failed|cancelling|cancelled
	Attempt         int32  `protobuf:"varint,4,opt,name=attempt,proto3" json:"attempt,omitempty"`
	Owner           string `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`                             // empty for internal runs
	EnqueuedAt      string `protobuf:"bytes,6,opt,name=enqueued_at,json=enqueuedAt,proto3" json:"enqueued_at,omitempty"` // RFC3339
	StartedAt       string `protobuf:"bytes,7,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`    // RFC3339, empty while queued
	FinishedAt      string `protobuf:"bytes,8,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"` // RFC3339, empty while queued/running
	LastError       string `protobuf:"bytes,9,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
	CancelRequested bool   `protobuf:"varint,10,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	ResultJson      string `protobuf:"bytes,11,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"` // the job's result payload as JSON
	// contains filtered or unexported fields
}

type JobRunnerInfo struct {
	Node              string           `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Error             string           `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Workers           int32            `protobuf:"varint,3,opt,name=workers,proto3" json:"workers,omitempty"`
	Busy              int32            `protobuf:"varint,4,opt,name=busy,proto3" json:"busy,omitempty"`
	StoreWired        bool             `protobuf:"varint,5,opt,name=store_wired,json=storeWired,proto3" json:"store_wired,omitempty"`
	Jobs              []*JobDefinition `protobuf:"bytes,6,rep,name=jobs,proto3" json:"jobs,omitempty"`
	InFlightPeriodics []string         `protobuf:"bytes,7,rep,name=in_flight_periodics,json=inFlightPeriodics,proto3" json:"in_flight_periodics,omitempty"`
	ActiveRuns        []*ActiveJobRun  `protobuf:"bytes,8,rep,name=active_runs,json=activeRuns,proto3" json:"active_runs,omitempty"`
	// contains filtered or unexported fields
}

type ListInvocationsRequest struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

type ListInvocationsResponse struct {
	Invocations []*InvocationSpec `protobuf:"bytes,1,rep,name=invocations,proto3" json:"invocations,omitempty"`
	// contains filtered or unexported fields
}

type ListJobRunsRequest struct {
	Job      string   `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Owner    string   `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	States   []string `protobuf:"bytes,3,rep,name=states,proto3" json:"states,omitempty"`
	Internal bool     `protobuf:"varint,4,opt,name=internal,proto3" json:"internal,omitempty"`
	Limit    int32    `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset   int32    `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type ListJobRunsResponse struct {
	Runs []*JobRun `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

type ListServicesRequest struct {

	// service optionally filters to a single service name.
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

type ListServicesResponse struct {
	Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

type Node struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// state is one of ready|degraded|offline|draining.
	State    string            `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

type NodeResult struct {

	// node is the id of the node that produced this result.
	Node string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// result_json is the invocation's redacted, serializable result as JSON.
	ResultJson string `protobuf:"bytes,2,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
	// error is set (per node) when the invocation failed on that node.
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

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

type RequestAdminResponse struct {

	// token is a short-TTL, admin-only token (scope map {admin}, no user key).
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// expires_at is the token expiry, in seconds since the Unix epoch.
	ExpiresAt int64 `protobuf:"varint,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

type ServerInfo struct {
	Version       string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Build         string `protobuf:"bytes,2,opt,name=build,proto3" json:"build,omitempty"`
	GoVersion     string `protobuf:"bytes,3,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
	UptimeSeconds int64  `protobuf:"varint,4,opt,name=uptime_seconds,json=uptimeSeconds,proto3" json:"uptime_seconds,omitempty"`
	Host          string `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"`
	Pid           int32  `protobuf:"varint,6,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

type Service struct {
	Name  string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Nodes []*Node `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

type ServiceHealth struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// state is the roll-up across the service's nodes.
	State string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	Ready int32  `protobuf:"varint,3,opt,name=ready,proto3" json:"ready,omitempty"`
	Total int32  `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

type TriggerJobRequest struct {
	Job string `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

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

type UnimplementedAdminAPIServer struct {
}

type UnsafeAdminAPIServer interface {
	// contains filtered or unexported methods
}