rpcpb

type ActuatedAsset struct {

	// The actual state of the asset post actuation (as scanned by the actuator).
	State *modelpb.AssetState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

type ActuationsClient interface {
	// Called by the actuator before it starts updating a deployment.
	//
	// The request contains the intended and current states of all assets in the
	// deployment. For each asset the backend responds if it should be actuated
	// or skipped.
	BeginActuation(ctx context.Context, in *BeginActuationRequest, opts ...grpc.CallOption) (*BeginActuationResponse, error)
	// Called by the actuator after it updated all assets it was asked to actuate.
	//
	// If there were no assets that needed actuation, this call is skipped.
	EndActuation(ctx context.Context, in *EndActuationRequest, opts ...grpc.CallOption) (*EndActuationResponse, error)
}

type ActuationsServer interface {
	// Called by the actuator before it starts updating a deployment.
	//
	// The request contains the intended and current states of all assets in the
	// deployment. For each asset the backend responds if it should be actuated
	// or skipped.
	BeginActuation(context.Context, *BeginActuationRequest) (*BeginActuationResponse, error)
	// Called by the actuator after it updated all assets it was asked to actuate.
	//
	// If there were no assets that needed actuation, this call is skipped.
	EndActuation(context.Context, *EndActuationRequest) (*EndActuationResponse, error)
	// contains filtered or unexported methods
}

type AssetToActuate struct {

	// Asset configuration as defined in the IaC repo.
	Config *modelpb.AssetConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// The intended state of the asset as defined in the IaC repo.
	IntendedState *modelpb.AssetState `protobuf:"bytes,2,opt,name=intended_state,json=intendedState,proto3" json:"intended_state,omitempty"`
	// The actual state of the asset (as scanned by the actuator).
	ReportedState *modelpb.AssetState `protobuf:"bytes,3,opt,name=reported_state,json=reportedState,proto3" json:"reported_state,omitempty"`
	// contains filtered or unexported fields
}

type AssetsClient interface {
	// GetAsset returns an Asset given its ID.
	GetAsset(ctx context.Context, in *GetAssetRequest, opts ...grpc.CallOption) (*modelpb.Asset, error)
	// ListAssets lists assets matching specified filters (if any).
	ListAssets(ctx context.Context, in *ListAssetsRequest, opts ...grpc.CallOption) (*ListAssetsResponse, error)
	// ListAssetHistory fetches an asset and its actuation history.
	ListAssetHistory(ctx context.Context, in *ListAssetHistoryRequest, opts ...grpc.CallOption) (*ListAssetHistoryResponse, error)
}

type AssetsServer interface {
	// GetAsset returns an Asset given its ID.
	GetAsset(context.Context, *GetAssetRequest) (*modelpb.Asset, error)
	// ListAssets lists assets matching specified filters (if any).
	ListAssets(context.Context, *ListAssetsRequest) (*ListAssetsResponse, error)
	// ListAssetHistory fetches an asset and its actuation history.
	ListAssetHistory(context.Context, *ListAssetHistoryRequest) (*ListAssetHistoryResponse, error)
	// contains filtered or unexported methods
}

type BeginActuationRequest struct {

	// A new actuation to perform.
	//
	// Must have a new unique ID and be in EXECUTING state. If an actuation with
	// such ID already exists, this request is assumed to be a retry and handled
	// as such (perhaps producing FAILED_PRECONDITION response if something
	// doesn't add up).
	Actuation *modelpb.Actuation `protobuf:"bytes,1,opt,name=actuation,proto3" json:"actuation,omitempty"`
	// Assets to be actuated as a map asset_id => AssetToActuate.
	//
	// For each asset the BeginActuationResponse would contain the corresponding
	// ActuationDecision.
	Assets map[string]*AssetToActuate `` /* 153-byte string literal not displayed */
	// Metadata of all artifacts referenced in `assets`.
	Artifacts []*modelpb.Artifact `protobuf:"bytes,3,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	// contains filtered or unexported fields
}

type BeginActuationResponse struct {

	// Per-asset decision whether to proceed with the actuation or to skip it.
	Decisions map[string]*modelpb.ActuationDecision `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

type EndActuationRequest struct {

	// ID of the actuation that was passed to BeginActuation RPC previously.
	ActuationId string `protobuf:"bytes,1,opt,name=actuation_id,json=actuationId,proto3" json:"actuation_id,omitempty"`
	// Error details if the actuation failed (perhaps partially).
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// Link to a human-readable actuation log (if available).
	LogUrl string `protobuf:"bytes,3,opt,name=log_url,json=logUrl,proto3" json:"log_url,omitempty"`
	// The state of the actuated (non-skipped) assets post-actuation.
	Assets map[string]*ActuatedAsset `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

type GetAssetRequest struct {
	AssetId string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	// contains filtered or unexported fields
}

type ListAssetHistoryRequest struct {

	// ID of an asset to fetch the history of.
	AssetId string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	// ID of the most recent historical entry to fetch (for pagination).
	LatestHistoryId int64 `protobuf:"varint,2,opt,name=latest_history_id,json=latestHistoryId,proto3" json:"latest_history_id,omitempty"`
	// Limit on the number of entries to fetch.
	Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type ListAssetHistoryResponse struct {

	// Asset at its current state.
	Asset *modelpb.Asset `protobuf:"bytes,1,opt,name=asset,proto3" json:"asset,omitempty"`
	// A historical entry being recorded right now, if any.
	Current *modelpb.AssetHistory `protobuf:"bytes,2,opt,name=current,proto3" json:"current,omitempty"`
	// ID of the most recently recorded and committed entry (for pagination back).
	LastRecordedHistoryId int64 `` /* 129-byte string literal not displayed */
	// Historical records starting with `latest_history_id`.
	History []*modelpb.AssetHistory `protobuf:"bytes,4,rep,name=history,proto3" json:"history,omitempty"`
	// contains filtered or unexported fields
}

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

type ListAssetsResponse struct {

	// Assets in order of their IDs.
	Assets []*modelpb.Asset `protobuf:"bytes,1,rep,name=assets,proto3" json:"assets,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedActuationsServer struct {
}

type UnimplementedAssetsServer struct {
}

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

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