proto

type AgentConfig struct {
	Loki    *LokiConfig         `protobuf:"bytes,1,opt,name=loki,proto3" json:"loki,omitempty"`
	Runtime *AgentRuntimeConfig `protobuf:"bytes,2,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// contains filtered or unexported fields
}

type AgentConfigStatus struct {
	Loki    *LokiConfig         `protobuf:"bytes,1,opt,name=loki,proto3" json:"loki,omitempty"`
	Runtime *AgentRuntimeStatus `protobuf:"bytes,2,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// contains filtered or unexported fields
}

type AgentHello struct {
	ClientId     string            `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	ClientSecret string            `protobuf:"bytes,2,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`
	Version      string            `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	TenantId     string            `protobuf:"bytes,4,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Labels       map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AgentRuntimeConfig struct {
	DisHost      string `protobuf:"bytes,1,opt,name=dis_host,json=disHost,proto3" json:"dis_host,omitempty"`
	DisUser      string `protobuf:"bytes,2,opt,name=dis_user,json=disUser,proto3" json:"dis_user,omitempty"`
	DisPassword  string `protobuf:"bytes,3,opt,name=dis_password,json=disPassword,proto3" json:"dis_password,omitempty"` // write-only
	JdbcPort     string `protobuf:"bytes,4,opt,name=jdbc_port,json=jdbcPort,proto3" json:"jdbc_port,omitempty"`
	JavaPath     string `protobuf:"bytes,5,opt,name=java_path,json=javaPath,proto3" json:"java_path,omitempty"`
	TenantId     string `protobuf:"bytes,6,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ClientSecret string `protobuf:"bytes,7,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`  // write-only
	ForceRestart bool   `protobuf:"varint,8,opt,name=force_restart,json=forceRestart,proto3" json:"force_restart,omitempty"` // when true, agent should reconnect/apply immediately
	// contains filtered or unexported fields
}

type AgentRuntimeStatus struct {
	DisHost         string `protobuf:"bytes,1,opt,name=dis_host,json=disHost,proto3" json:"dis_host,omitempty"`
	DisUser         string `protobuf:"bytes,2,opt,name=dis_user,json=disUser,proto3" json:"dis_user,omitempty"`
	JdbcPort        string `protobuf:"bytes,3,opt,name=jdbc_port,json=jdbcPort,proto3" json:"jdbc_port,omitempty"`
	JavaPath        string `protobuf:"bytes,4,opt,name=java_path,json=javaPath,proto3" json:"java_path,omitempty"`
	TenantId        string `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	HasPassword     bool   `protobuf:"varint,6,opt,name=has_password,json=hasPassword,proto3" json:"has_password,omitempty"`
	HasClientSecret bool   `protobuf:"varint,7,opt,name=has_client_secret,json=hasClientSecret,proto3" json:"has_client_secret,omitempty"`
	// contains filtered or unexported fields
}

type AgentServiceClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AgentToServer, ServerToAgent], error)
}

type AgentServiceServer interface {
	Connect(grpc.BidiStreamingServer[AgentToServer, ServerToAgent]) error
	// contains filtered or unexported methods
}

type AgentService_ConnectClient = grpc.BidiStreamingClient[AgentToServer, ServerToAgent]

type AgentService_ConnectServer = grpc.BidiStreamingServer[AgentToServer, ServerToAgent]

type AgentToServer struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*AgentToServer_Hello
	//	*AgentToServer_JobResult
	//	*AgentToServer_Heartbeat
	//	*AgentToServer_Log
	Payload isAgentToServer_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type AgentToServer_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,3,opt,name=heartbeat,proto3,oneof"`
}

type AgentToServer_Hello struct {
	Hello *AgentHello `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}

type AgentToServer_JobResult struct {
	JobResult *JobResult `protobuf:"bytes,2,opt,name=job_result,json=jobResult,proto3,oneof"`
}

type AgentToServer_Log struct {
	Log *LogEntry `protobuf:"bytes,4,opt,name=log,proto3,oneof"`
}

type Heartbeat struct {
	At       *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=at,proto3" json:"at,omitempty"`
	AgentId  string                 `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	TenantId string                 `protobuf:"bytes,3,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

type JobKind int32

type JobRequest struct {
	JobId      string  `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Kind       JobKind `protobuf:"varint,2,opt,name=kind,proto3,enum=bridge.JobKind" json:"kind,omitempty"`
	Sql        string  `protobuf:"bytes,3,opt,name=sql,proto3" json:"sql,omitempty"`
	IncludeSrc bool    `protobuf:"varint,4,opt,name=include_src,json=includeSrc,proto3" json:"include_src,omitempty"`
	// contains filtered or unexported fields
}

type JobResult struct {
	JobId        string             `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Status       Status             `protobuf:"varint,2,opt,name=status,proto3,enum=bridge.Status" json:"status,omitempty"`
	Message      string             `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Rows         []*Row             `protobuf:"bytes,4,rep,name=rows,proto3" json:"rows,omitempty"`
	ConfigStatus *AgentConfigStatus `protobuf:"bytes,5,opt,name=config_status,json=configStatus,proto3" json:"config_status,omitempty"`
	// contains filtered or unexported fields
}

type LogEntry struct {
	At      *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=at,proto3" json:"at,omitempty"`
	Level   string                 `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"`
	Message string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Fields  map[string]string      `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type LokiConfig struct {
	Url        string            `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	TenantId   string            `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ApiKey     string            `protobuf:"bytes,3,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	AuthHeader string            `protobuf:"bytes,4,opt,name=auth_header,json=authHeader,proto3" json:"auth_header,omitempty"`
	Labels     map[string]string `` /* 139-byte string literal not displayed */
	MinLevel   string            `protobuf:"bytes,6,opt,name=min_level,json=minLevel,proto3" json:"min_level,omitempty"`
	// contains filtered or unexported fields
}

type Row struct {
	Fields map[string]*structpb.Value `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ServerToAgent struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*ServerToAgent_JobRequest
	//	*ServerToAgent_Config
	Payload isServerToAgent_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type ServerToAgent_Config struct {
	Config *AgentConfig `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type ServerToAgent_JobRequest struct {
	JobRequest *JobRequest `protobuf:"bytes,1,opt,name=job_request,json=jobRequest,proto3,oneof"`
}

type Status int32

type UnimplementedAgentServiceServer struct{}

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