v1

type DevloopGatewayServiceClient interface {
	// Communicate handles all bidirectional communication between devloop and the gateway.
	Communicate(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[DevloopMessage, DevloopMessage], error)
}

type DevloopGatewayServiceServer interface {
	// Communicate handles all bidirectional communication between devloop and the gateway.
	Communicate(grpc.BidiStreamingServer[DevloopMessage, DevloopMessage]) error
}

type DevloopGatewayService_CommunicateClient = grpc.BidiStreamingClient[DevloopMessage, DevloopMessage]

type DevloopGatewayService_CommunicateServer = grpc.BidiStreamingServer[DevloopMessage, DevloopMessage]

type DevloopMessage struct {
	CorrelationId string `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` // Used to correlate requests and responses
	// Types that are valid to be assigned to Content:
	//
	//	*DevloopMessage_RegisterRequest
	//	*DevloopMessage_UnregisterRequest
	//	*DevloopMessage_LogLine
	//	*DevloopMessage_UpdateRuleStatusRequest
	//	*DevloopMessage_GetConfigResponse
	//	*DevloopMessage_GetRuleStatusResponse
	//	*DevloopMessage_TriggerRuleResponse
	//	*DevloopMessage_ListWatchedPathsResponse
	//	*DevloopMessage_ReadFileContentResponse
	//	*DevloopMessage_TriggerRuleRequest
	//	*DevloopMessage_GetConfigRequest
	//	*DevloopMessage_GetRuleStatusRequest
	//	*DevloopMessage_ListWatchedPathsRequest
	//	*DevloopMessage_ReadFileContentRequest
	//	*DevloopMessage_GetHistoricalLogsRequest
	Content isDevloopMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type DevloopMessage_GetConfigRequest struct {
	GetConfigRequest *GetConfigRequest `protobuf:"bytes,12,opt,name=get_config_request,json=getConfigRequest,proto3,oneof"`
}

type DevloopMessage_GetConfigResponse struct {
	GetConfigResponse *GetConfigResponse `protobuf:"bytes,6,opt,name=get_config_response,json=getConfigResponse,proto3,oneof"`
}

type DevloopMessage_GetHistoricalLogsRequest struct {
	GetHistoricalLogsRequest *GetHistoricalLogsRequest `protobuf:"bytes,16,opt,name=get_historical_logs_request,json=getHistoricalLogsRequest,proto3,oneof"`
}

type DevloopMessage_GetRuleStatusRequest struct {
	GetRuleStatusRequest *GetRuleStatusRequest `protobuf:"bytes,13,opt,name=get_rule_status_request,json=getRuleStatusRequest,proto3,oneof"`
}

type DevloopMessage_GetRuleStatusResponse struct {
	GetRuleStatusResponse *GetRuleStatusResponse `protobuf:"bytes,7,opt,name=get_rule_status_response,json=getRuleStatusResponse,proto3,oneof"`
}

type DevloopMessage_ListWatchedPathsRequest struct {
	ListWatchedPathsRequest *ListWatchedPathsRequest `protobuf:"bytes,14,opt,name=list_watched_paths_request,json=listWatchedPathsRequest,proto3,oneof"`
}

type DevloopMessage_ListWatchedPathsResponse struct {
	ListWatchedPathsResponse *ListWatchedPathsResponse `protobuf:"bytes,9,opt,name=list_watched_paths_response,json=listWatchedPathsResponse,proto3,oneof"`
}

type DevloopMessage_LogLine struct {
	LogLine *LogLine `protobuf:"bytes,4,opt,name=log_line,json=logLine,proto3,oneof"`
}

type DevloopMessage_ReadFileContentRequest struct {
	ReadFileContentRequest *ReadFileContentRequest `protobuf:"bytes,15,opt,name=read_file_content_request,json=readFileContentRequest,proto3,oneof"`
}

type DevloopMessage_ReadFileContentResponse struct {
	ReadFileContentResponse *ReadFileContentResponse `protobuf:"bytes,10,opt,name=read_file_content_response,json=readFileContentResponse,proto3,oneof"`
}

type DevloopMessage_RegisterRequest struct {
	// Messages sent from devloop to gateway
	RegisterRequest *RegisterRequest `protobuf:"bytes,2,opt,name=register_request,json=registerRequest,proto3,oneof"`
}

type DevloopMessage_TriggerRuleRequest struct {
	// Messages sent from gateway to devloop
	TriggerRuleRequest *TriggerRuleRequest `protobuf:"bytes,11,opt,name=trigger_rule_request,json=triggerRuleRequest,proto3,oneof"`
}

type DevloopMessage_TriggerRuleResponse struct {
	TriggerRuleResponse *TriggerRuleResponse `protobuf:"bytes,8,opt,name=trigger_rule_response,json=triggerRuleResponse,proto3,oneof"`
}

type DevloopMessage_UnregisterRequest struct {
	UnregisterRequest *UnregisterRequest `protobuf:"bytes,3,opt,name=unregister_request,json=unregisterRequest,proto3,oneof"`
}

type DevloopMessage_UpdateRuleStatusRequest struct {
	UpdateRuleStatusRequest *UpdateRuleStatusRequest `protobuf:"bytes,5,opt,name=update_rule_status_request,json=updateRuleStatusRequest,proto3,oneof"`
}

type GatewayClientServiceClient interface {
	// List all registered devloop projects.
	ListProjects(ctx context.Context, in *ListProjectsRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
	// Get the configuration for a specific devloop project.
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
	// Get the detailed status of a specific rule within a project.
	GetRuleStatus(ctx context.Context, in *GetRuleStatusRequest, opts ...grpc.CallOption) (*GetRuleStatusResponse, error)
	// Manually trigger a specific rule in a devloop project.
	TriggerRuleClient(ctx context.Context, in *TriggerRuleClientRequest, opts ...grpc.CallOption) (*TriggerRuleClientResponse, error)
	// List all glob patterns being watched by a specific devloop project.
	ListWatchedPaths(ctx context.Context, in *ListWatchedPathsRequest, opts ...grpc.CallOption) (*ListWatchedPathsResponse, error)
	// Read and return the content of a specific file within a devloop project.
	ReadFileContent(ctx context.Context, in *ReadFileContentRequest, opts ...grpc.CallOption) (*ReadFileContentResponse, error)
	// Stream real-time logs for a specific rule in a project.
	StreamLogsClient(ctx context.Context, in *StreamLogsClientRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogLine], error)
	// Retrieve historical logs for a specific rule, with optional time filtering.
	GetHistoricalLogsClient(ctx context.Context, in *GetHistoricalLogsClientRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogLine], error)
}

type GatewayClientServiceServer interface {
	// List all registered devloop projects.
	ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)
	// Get the configuration for a specific devloop project.
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
	// Get the detailed status of a specific rule within a project.
	GetRuleStatus(context.Context, *GetRuleStatusRequest) (*GetRuleStatusResponse, error)
	// Manually trigger a specific rule in a devloop project.
	TriggerRuleClient(context.Context, *TriggerRuleClientRequest) (*TriggerRuleClientResponse, error)
	// List all glob patterns being watched by a specific devloop project.
	ListWatchedPaths(context.Context, *ListWatchedPathsRequest) (*ListWatchedPathsResponse, error)
	// Read and return the content of a specific file within a devloop project.
	ReadFileContent(context.Context, *ReadFileContentRequest) (*ReadFileContentResponse, error)
	// Stream real-time logs for a specific rule in a project.
	StreamLogsClient(*StreamLogsClientRequest, grpc.ServerStreamingServer[LogLine]) error
	// Retrieve historical logs for a specific rule, with optional time filtering.
	GetHistoricalLogsClient(*GetHistoricalLogsClientRequest, grpc.ServerStreamingServer[LogLine]) error
}

type GatewayClientService_GetHistoricalLogsClientClient = grpc.ServerStreamingClient[LogLine]

type GatewayClientService_GetHistoricalLogsClientServer = grpc.ServerStreamingServer[LogLine]

type GatewayClientService_StreamLogsClientClient = grpc.ServerStreamingClient[LogLine]

type GatewayClientService_StreamLogsClientServer = grpc.ServerStreamingServer[LogLine]

type GetConfigRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

type GetConfigResponse struct {
	ConfigJson []byte `protobuf:"bytes,1,opt,name=config_json,json=configJson,proto3" json:"config_json,omitempty"`
	// contains filtered or unexported fields
}

type GetHistoricalLogsClientRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	RuleName  string `protobuf:"bytes,2,opt,name=rule_name,json=ruleName,proto3" json:"rule_name,omitempty"`
	Filter    string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	StartTime int64  `protobuf:"varint,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // Unix timestamp in milliseconds, for logs after this time
	EndTime   int64  `protobuf:"varint,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`       // Unix timestamp in milliseconds, for logs before this time
	// contains filtered or unexported fields
}

type GetHistoricalLogsRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	RuleName  string `protobuf:"bytes,2,opt,name=rule_name,json=ruleName,proto3" json:"rule_name,omitempty"`
	Filter    string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	StartTime int64  `protobuf:"varint,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // Unix timestamp in milliseconds, for logs after this time
	EndTime   int64  `protobuf:"varint,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`       // Unix timestamp in milliseconds, for logs before this time
	// contains filtered or unexported fields
}

type GetRuleStatusRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	RuleName  string `protobuf:"bytes,2,opt,name=rule_name,json=ruleName,proto3" json:"rule_name,omitempty"`
	// contains filtered or unexported fields
}

type GetRuleStatusResponse struct {
	RuleStatus *RuleStatus `protobuf:"bytes,1,opt,name=rule_status,json=ruleStatus,proto3" json:"rule_status,omitempty"`
	// contains filtered or unexported fields
}

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

type ListProjectsResponse struct {
	Projects []*ListProjectsResponse_Project `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
	// contains filtered or unexported fields
}

type ListProjectsResponse_Project struct {
	ProjectId   string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ProjectRoot string `protobuf:"bytes,2,opt,name=project_root,json=projectRoot,proto3" json:"project_root,omitempty"`
	Status      string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` // e.g., "CONNECTED", "DISCONNECTED"
	// contains filtered or unexported fields
}

type ListWatchedPathsRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

type ListWatchedPathsResponse struct {
	Paths []string `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`
	// contains filtered or unexported fields
}

type LogLine struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	RuleName  string `protobuf:"bytes,2,opt,name=rule_name,json=ruleName,proto3" json:"rule_name,omitempty"`
	Line      string `protobuf:"bytes,3,opt,name=line,proto3" json:"line,omitempty"`
	Timestamp int64  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Unix timestamp in milliseconds
	// contains filtered or unexported fields
}

type ProjectInfo struct {
	ProjectId   string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ProjectRoot string `protobuf:"bytes,2,opt,name=project_root,json=projectRoot,proto3" json:"project_root,omitempty"`
	// contains filtered or unexported fields
}

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

type ReadFileContentResponse struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

type RegisterRequest struct {
	ProjectInfo *ProjectInfo `protobuf:"bytes,1,opt,name=project_info,json=projectInfo,proto3" json:"project_info,omitempty"`
	// contains filtered or unexported fields
}

type RuleStatus struct {
	ProjectId       string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	RuleName        string `protobuf:"bytes,2,opt,name=rule_name,json=ruleName,proto3" json:"rule_name,omitempty"`
	IsRunning       bool   `protobuf:"varint,3,opt,name=is_running,json=isRunning,proto3" json:"is_running,omitempty"`
	StartTime       int64  `protobuf:"varint,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`                    // Unix timestamp in milliseconds, if running
	LastBuildTime   int64  `protobuf:"varint,5,opt,name=last_build_time,json=lastBuildTime,proto3" json:"last_build_time,omitempty"`      // Unix timestamp in milliseconds, if not running
	LastBuildStatus string `protobuf:"bytes,6,opt,name=last_build_status,json=lastBuildStatus,proto3" json:"last_build_status,omitempty"` // e.g., "SUCCESS", "FAILED", "RUNNING", "IDLE"
	// contains filtered or unexported fields
}

type StreamLogsClientRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	RuleName  string `protobuf:"bytes,2,opt,name=rule_name,json=ruleName,proto3" json:"rule_name,omitempty"`
	Filter    string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type TriggerRuleClientRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	RuleName  string `protobuf:"bytes,2,opt,name=rule_name,json=ruleName,proto3" json:"rule_name,omitempty"`
	// contains filtered or unexported fields
}

type TriggerRuleClientResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type TriggerRuleRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	RuleName  string `protobuf:"bytes,2,opt,name=rule_name,json=ruleName,proto3" json:"rule_name,omitempty"`
	// contains filtered or unexported fields
}

type TriggerRuleResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedDevloopGatewayServiceServer struct{}

type UnimplementedGatewayClientServiceServer struct{}

type UnregisterRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

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

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

type UpdateRuleStatusRequest struct {
	RuleStatus *RuleStatus `protobuf:"bytes,1,opt,name=rule_status,json=ruleStatus,proto3" json:"rule_status,omitempty"`
	// contains filtered or unexported fields
}