proto

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

type AddContextSourceResponse struct {
	Source *ContextSource `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

type ContextResource 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"`
	Source      string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	SourcePath  string `protobuf:"bytes,4,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	ContentHash string `protobuf:"bytes,5,opt,name=content_hash,json=contentHash,proto3" json:"content_hash,omitempty"`
	SizeBytes   uint64 `protobuf:"varint,6,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	Status      string `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
	Error       string `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	Name        string `protobuf:"bytes,9,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,10,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

type ContextSnapshot struct {
	Version       uint64             `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	AggregateHash string             `protobuf:"bytes,2,opt,name=aggregate_hash,json=aggregateHash,proto3" json:"aggregate_hash,omitempty"`
	Resources     []*ContextResource `protobuf:"bytes,3,rep,name=resources,proto3" json:"resources,omitempty"`
	PayloadBytes  uint64             `protobuf:"varint,4,opt,name=payload_bytes,json=payloadBytes,proto3" json:"payload_bytes,omitempty"`
	SnapshotError string             `protobuf:"bytes,5,opt,name=snapshot_error,json=snapshotError,proto3" json:"snapshot_error,omitempty"`
	// contains filtered or unexported fields
}

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

type ContextSnapshotResponse struct {
	Snapshot *ContextSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

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

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

type ContextSourcesResponse struct {
	Sources []*ContextSource `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	// contains filtered or unexported fields
}

type DRPCAgentSocketClient interface {
	DRPCConn() drpc.Conn

	Ping(ctx context.Context, in *PingRequest) (*PingResponse, error)
	SyncStart(ctx context.Context, in *SyncStartRequest) (*SyncStartResponse, error)
	SyncWant(ctx context.Context, in *SyncWantRequest) (*SyncWantResponse, error)
	SyncComplete(ctx context.Context, in *SyncCompleteRequest) (*SyncCompleteResponse, error)
	SyncReady(ctx context.Context, in *SyncReadyRequest) (*SyncReadyResponse, error)
	SyncStatus(ctx context.Context, in *SyncStatusRequest) (*SyncStatusResponse, error)
	SyncList(ctx context.Context, in *SyncListRequest) (*SyncListResponse, error)
	UpdateAppStatus(ctx context.Context, in *proto1.UpdateAppStatusRequest) (*proto1.UpdateAppStatusResponse, error)
	ContextSources(ctx context.Context, in *ContextSourcesRequest) (*ContextSourcesResponse, error)
	GetContextSource(ctx context.Context, in *GetContextSourceRequest) (*GetContextSourceResponse, error)
	AddContextSource(ctx context.Context, in *AddContextSourceRequest) (*AddContextSourceResponse, error)
	RemoveContextSource(ctx context.Context, in *RemoveContextSourceRequest) (*RemoveContextSourceResponse, error)
	GetContextSnapshot(ctx context.Context, in *ContextSnapshotRequest) (*ContextSnapshotResponse, error)
	ResyncContext(ctx context.Context, in *ResyncContextRequest) (*ResyncContextResponse, error)
}

type DRPCAgentSocketDescription struct{}

type DRPCAgentSocketServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	SyncStart(context.Context, *SyncStartRequest) (*SyncStartResponse, error)
	SyncWant(context.Context, *SyncWantRequest) (*SyncWantResponse, error)
	SyncComplete(context.Context, *SyncCompleteRequest) (*SyncCompleteResponse, error)
	SyncReady(context.Context, *SyncReadyRequest) (*SyncReadyResponse, error)
	SyncStatus(context.Context, *SyncStatusRequest) (*SyncStatusResponse, error)
	SyncList(context.Context, *SyncListRequest) (*SyncListResponse, error)
	UpdateAppStatus(context.Context, *proto1.UpdateAppStatusRequest) (*proto1.UpdateAppStatusResponse, error)
	ContextSources(context.Context, *ContextSourcesRequest) (*ContextSourcesResponse, error)
	GetContextSource(context.Context, *GetContextSourceRequest) (*GetContextSourceResponse, error)
	AddContextSource(context.Context, *AddContextSourceRequest) (*AddContextSourceResponse, error)
	RemoveContextSource(context.Context, *RemoveContextSourceRequest) (*RemoveContextSourceResponse, error)
	GetContextSnapshot(context.Context, *ContextSnapshotRequest) (*ContextSnapshotResponse, error)
	ResyncContext(context.Context, *ResyncContextRequest) (*ResyncContextResponse, error)
}

type DRPCAgentSocketUnimplementedServer struct{}

type DRPCAgentSocket_AddContextSourceStream interface {
	drpc.Stream
	SendAndClose(*AddContextSourceResponse) error
}

type DRPCAgentSocket_ContextSourcesStream interface {
	drpc.Stream
	SendAndClose(*ContextSourcesResponse) error
}

type DRPCAgentSocket_GetContextSnapshotStream interface {
	drpc.Stream
	SendAndClose(*ContextSnapshotResponse) error
}

type DRPCAgentSocket_GetContextSourceStream interface {
	drpc.Stream
	SendAndClose(*GetContextSourceResponse) error
}

type DRPCAgentSocket_PingStream interface {
	drpc.Stream
	SendAndClose(*PingResponse) error
}

type DRPCAgentSocket_RemoveContextSourceStream interface {
	drpc.Stream
	SendAndClose(*RemoveContextSourceResponse) error
}

type DRPCAgentSocket_ResyncContextStream interface {
	drpc.Stream
	SendAndClose(*ResyncContextResponse) error
}

type DRPCAgentSocket_SyncCompleteStream interface {
	drpc.Stream
	SendAndClose(*SyncCompleteResponse) error
}

type DRPCAgentSocket_SyncListStream interface {
	drpc.Stream
	SendAndClose(*SyncListResponse) error
}

type DRPCAgentSocket_SyncReadyStream interface {
	drpc.Stream
	SendAndClose(*SyncReadyResponse) error
}

type DRPCAgentSocket_SyncStartStream interface {
	drpc.Stream
	SendAndClose(*SyncStartResponse) error
}

type DRPCAgentSocket_SyncStatusStream interface {
	drpc.Stream
	SendAndClose(*SyncStatusResponse) error
}

type DRPCAgentSocket_SyncWantStream interface {
	drpc.Stream
	SendAndClose(*SyncWantResponse) error
}

type DRPCAgentSocket_UpdateAppStatusStream interface {
	drpc.Stream
	SendAndClose(*proto1.UpdateAppStatusResponse) error
}

type DependencyInfo struct {
	Unit           string `protobuf:"bytes,1,opt,name=unit,proto3" json:"unit,omitempty"`
	DependsOn      string `protobuf:"bytes,2,opt,name=depends_on,json=dependsOn,proto3" json:"depends_on,omitempty"`
	RequiredStatus string `protobuf:"bytes,3,opt,name=required_status,json=requiredStatus,proto3" json:"required_status,omitempty"`
	CurrentStatus  string `protobuf:"bytes,4,opt,name=current_status,json=currentStatus,proto3" json:"current_status,omitempty"`
	IsSatisfied    bool   `protobuf:"varint,5,opt,name=is_satisfied,json=isSatisfied,proto3" json:"is_satisfied,omitempty"`
	// contains filtered or unexported fields
}

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

type GetContextSourceResponse struct {
	Source *ContextSource `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

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

type ResyncContextResponse struct {
	Snapshot *ContextSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type SyncListResponse struct {
	Units []*UnitInfo `protobuf:"bytes,1,rep,name=units,proto3" json:"units,omitempty"`
	// contains filtered or unexported fields
}

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

type SyncReadyResponse struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type SyncStatusResponse struct {
	Status       string            `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IsReady      bool              `protobuf:"varint,2,opt,name=is_ready,json=isReady,proto3" json:"is_ready,omitempty"`
	Dependencies []*DependencyInfo `protobuf:"bytes,3,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

type SyncWantRequest struct {
	Unit      string `protobuf:"bytes,1,opt,name=unit,proto3" json:"unit,omitempty"`
	DependsOn string `protobuf:"bytes,2,opt,name=depends_on,json=dependsOn,proto3" json:"depends_on,omitempty"`
	// contains filtered or unexported fields
}

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

type UnitInfo struct {
	Unit    string `protobuf:"bytes,1,opt,name=unit,proto3" json:"unit,omitempty"`
	Status  string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	IsReady bool   `protobuf:"varint,3,opt,name=is_ready,json=isReady,proto3" json:"is_ready,omitempty"`
	// contains filtered or unexported fields
}