proto

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 `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AgentServiceClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (AgentService_ConnectClient, error)
}

type AgentServiceServer interface {
	Connect(AgentService_ConnectServer) error
	// contains filtered or unexported methods
}

type AgentService_ConnectClient interface {
	Send(*AgentToServer) error
	Recv() (*ServerToAgent, error)
	grpc.ClientStream
}

type AgentService_ConnectServer interface {
	Send(*ServerToAgent) error
	Recv() (*AgentToServer, error)
	grpc.ServerStream
}

type AgentToServer struct {

	// Types that are assignable 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"`
	// 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      `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

type ServerToAgent struct {

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

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
}