jina

type DataRequestListProto struct {
	Requests []*DataRequestProto `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"` // requests in this list
	// contains filtered or unexported fields
}

type DataRequestProto struct {
	Header     *HeaderProto                       `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`         // header contains meta info defined by the user
	Parameters *structpb.Struct                   `protobuf:"bytes,2,opt,name=parameters,proto3" json:"parameters,omitempty"` // extra kwargs that will be used in executor
	Routes     []*RouteProto                      `protobuf:"bytes,3,rep,name=routes,proto3" json:"routes,omitempty"`         // status info on every routes
	Data       *DataRequestProto_DataContentProto `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`             // container for docs and groundtruths
	// contains filtered or unexported fields
}

type DataRequestProtoWoData struct {
	Header     *HeaderProto     `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`         // header contains meta info defined by the user
	Parameters *structpb.Struct `protobuf:"bytes,2,opt,name=parameters,proto3" json:"parameters,omitempty"` // extra kwargs that will be used in executor
	Routes     []*RouteProto    `protobuf:"bytes,3,rep,name=routes,proto3" json:"routes,omitempty"`         // status info on every routes
	// contains filtered or unexported fields
}

type DataRequestProto_DataContentProto struct {

	// Types that are assignable to Documents:
	//	*DataRequestProto_DataContentProto_Docs
	//	*DataRequestProto_DataContentProto_DocsBytes
	Documents isDataRequestProto_DataContentProto_Documents `protobuf_oneof:"documents"`
	// contains filtered or unexported fields
}

type DataRequestProto_DataContentProto_Docs struct {
	Docs *docarray.DocumentArrayProto `protobuf:"bytes,1,opt,name=docs,proto3,oneof"` // the docs in this request
}

type DataRequestProto_DataContentProto_DocsBytes struct {
	DocsBytes []byte `protobuf:"bytes,2,opt,name=docs_bytes,json=docsBytes,proto3,oneof"` // the docs in this request as bytes
}

type EndpointsProto struct {

	// list of endpoints exposed by an Executor
	Endpoints      []string `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	WriteEndpoints []string `protobuf:"bytes,2,rep,name=write_endpoints,json=writeEndpoints,proto3" json:"write_endpoints,omitempty"`
	// Dictionary containing input and output schema per endpoint
	Schemas *structpb.Struct `protobuf:"bytes,3,opt,name=schemas,proto3" json:"schemas,omitempty"` // extra kwargs that will be used in executor
	// contains filtered or unexported fields
}

type HeaderProto struct {
	RequestId      string       `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`                      // the unique ID of this request. Multiple requests with the same ID will be gathered
	Status         *StatusProto `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`                                             // status info
	ExecEndpoint   *string      `protobuf:"bytes,3,opt,name=exec_endpoint,json=execEndpoint,proto3,oneof" json:"exec_endpoint,omitempty"`       // the endpoint specified by `@requests(on='/abc')`
	TargetExecutor *string      `protobuf:"bytes,4,opt,name=target_executor,json=targetExecutor,proto3,oneof" json:"target_executor,omitempty"` // if set, the request is targeted to certain executor, regex strings
	Timeout        *uint32      `protobuf:"varint,5,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`                                    // epoch time in seconds after which the request should be dropped
	// contains filtered or unexported fields
}

type JinaDataRequestRPCClient interface {
	// Used for passing DataRequests to the Executors
	ProcessData(ctx context.Context, in *DataRequestListProto, opts ...grpc.CallOption) (*DataRequestProto, error)
}

type JinaDataRequestRPCServer interface {
	// Used for passing DataRequests to the Executors
	ProcessData(context.Context, *DataRequestListProto) (*DataRequestProto, error)
	// contains filtered or unexported methods
}

type JinaDiscoverEndpointsRPCClient interface {
	EndpointDiscovery(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*EndpointsProto, error)
}

type JinaDiscoverEndpointsRPCServer interface {
	EndpointDiscovery(context.Context, *emptypb.Empty) (*EndpointsProto, error)
	// contains filtered or unexported methods
}

type JinaExecutorRestoreClient interface {
	Restore(ctx context.Context, in *RestoreSnapshotCommand, opts ...grpc.CallOption) (*RestoreSnapshotStatusProto, error)
}

type JinaExecutorRestoreProgressClient interface {
	RestoreStatus(ctx context.Context, in *RestoreId, opts ...grpc.CallOption) (*RestoreSnapshotStatusProto, error)
}

type JinaExecutorRestoreProgressServer interface {
	RestoreStatus(context.Context, *RestoreId) (*RestoreSnapshotStatusProto, error)
	// contains filtered or unexported methods
}

type JinaExecutorRestoreServer interface {
	Restore(context.Context, *RestoreSnapshotCommand) (*RestoreSnapshotStatusProto, error)
	// contains filtered or unexported methods
}

type JinaExecutorSnapshotClient interface {
	Snapshot(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*SnapshotStatusProto, error)
}

type JinaExecutorSnapshotProgressClient interface {
	SnapshotStatus(ctx context.Context, in *SnapshotId, opts ...grpc.CallOption) (*SnapshotStatusProto, error)
}

type JinaExecutorSnapshotProgressServer interface {
	SnapshotStatus(context.Context, *SnapshotId) (*SnapshotStatusProto, error)
	// contains filtered or unexported methods
}

type JinaExecutorSnapshotServer interface {
	Snapshot(context.Context, *emptypb.Empty) (*SnapshotStatusProto, error)
	// contains filtered or unexported methods
}

type JinaGatewayDryRunRPCClient interface {
	DryRun(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*StatusProto, error)
}

type JinaGatewayDryRunRPCServer interface {
	DryRun(context.Context, *emptypb.Empty) (*StatusProto, error)
	// contains filtered or unexported methods
}

type JinaInfoProto struct {
	Jina map[string]string `` // information about the system running and package version information including jina
	/* 149-byte string literal not displayed */
	Envs map[string]string `` // the environment variable setting
	/* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type JinaInfoRPCClient interface {
	XStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*JinaInfoProto, error)
}

type JinaInfoRPCServer interface {
	XStatus(context.Context, *emptypb.Empty) (*JinaInfoProto, error)
	// contains filtered or unexported methods
}

type JinaRPCClient interface {
	// Pass in a Request and a filled Request with matches will be returned.
	Call(ctx context.Context, opts ...grpc.CallOption) (JinaRPC_CallClient, error)
}

type JinaRPCServer interface {
	// Pass in a Request and a filled Request with matches will be returned.
	Call(JinaRPC_CallServer) error
	// contains filtered or unexported methods
}

type JinaRPC_CallClient interface {
	Send(*DataRequestProto) error
	Recv() (*DataRequestProto, error)
	grpc.ClientStream
}

type JinaRPC_CallServer interface {
	Send(*DataRequestProto) error
	Recv() (*DataRequestProto, error)
	grpc.ServerStream
}

type JinaSingleDataRequestRPCClient interface {
	// Used for passing DataRequests to the Executors
	ProcessSingleData(ctx context.Context, in *DataRequestProto, opts ...grpc.CallOption) (*DataRequestProto, error)
}

type JinaSingleDataRequestRPCServer interface {
	// Used for passing DataRequests to the Executors
	ProcessSingleData(context.Context, *DataRequestProto) (*DataRequestProto, error)
	// contains filtered or unexported methods
}

type JinaSingleDocumentRequestRPCClient interface {
	// Used for streaming one document to the Executors
	StreamDoc(ctx context.Context, in *SingleDocumentRequestProto, opts ...grpc.CallOption) (JinaSingleDocumentRequestRPC_StreamDocClient, error)
}

type JinaSingleDocumentRequestRPCServer interface {
	// Used for streaming one document to the Executors
	StreamDoc(*SingleDocumentRequestProto, JinaSingleDocumentRequestRPC_StreamDocServer) error
	// contains filtered or unexported methods
}

type JinaSingleDocumentRequestRPC_StreamDocClient interface {
	Recv() (*SingleDocumentRequestProto, error)
	grpc.ClientStream
}

type JinaSingleDocumentRequestRPC_StreamDocServer interface {
	Send(*SingleDocumentRequestProto) error
	grpc.ServerStream
}

type RelatedEntity struct {
	Id      string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                 // unique id of the entity, like the name of a pod
	Address string  `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`                       // address of the entity, could be an IP address, domain name etc, does not include port
	Port    uint32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`                            // port this entity is listening on
	ShardId *uint32 `protobuf:"varint,4,opt,name=shard_id,json=shardId,proto3,oneof" json:"shard_id,omitempty"` // the id of the shard it belongs to, if it is a shard
	// contains filtered or unexported fields
}

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

type RestoreSnapshotCommand struct {

	// snapshot file
	SnapshotFile string `protobuf:"bytes,1,opt,name=snapshot_file,json=snapshotFile,proto3" json:"snapshot_file,omitempty"`
	// contains filtered or unexported fields
}

type RestoreSnapshotStatusProto struct {
	Id *RestoreId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // An ID for the Restore Job.
	// status code
	Status RestoreSnapshotStatusProto_Status `protobuf:"varint,2,opt,name=status,proto3,enum=jina.RestoreSnapshotStatusProto_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type RestoreSnapshotStatusProto_Status int32

type RouteProto struct {
	Executor  string                 `protobuf:"bytes,1,opt,name=executor,proto3" json:"executor,omitempty"`                    // the name of the BasePod
	StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // time when the Gateway starts sending to the Pod
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`       // time when the Gateway received it from the Pod
	Status    *StatusProto           `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`                        // the status of the execution
	// contains filtered or unexported fields
}

type SingleDocumentRequestProto struct {
	Header     *HeaderProto            `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`         // header contains meta info defined by the user
	Parameters *structpb.Struct        `protobuf:"bytes,2,opt,name=parameters,proto3" json:"parameters,omitempty"` // extra kwargs that will be used in executor
	Routes     []*RouteProto           `protobuf:"bytes,3,rep,name=routes,proto3" json:"routes,omitempty"`         // status info on every routes
	Document   *docarray.DocumentProto `protobuf:"bytes,4,opt,name=document,proto3" json:"document,omitempty"`     // the document in this request
	// contains filtered or unexported fields
}

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

type SnapshotStatusProto struct {
	Id *SnapshotId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // An ID for the Snapshot Job.
	// status code
	Status SnapshotStatusProto_Status `protobuf:"varint,2,opt,name=status,proto3,enum=jina.SnapshotStatusProto_Status" json:"status,omitempty"`
	// snapshot file
	SnapshotFile string `protobuf:"bytes,3,opt,name=snapshot_file,json=snapshotFile,proto3" json:"snapshot_file,omitempty"`
	// contains filtered or unexported fields
}

type SnapshotStatusProto_Status int32

type StatusProto struct {

	// status code
	Code StatusProto_StatusCode `protobuf:"varint,1,opt,name=code,proto3,enum=jina.StatusProto_StatusCode" json:"code,omitempty"`
	// error description of the very first exception
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// the details of the error
	Exception *StatusProto_ExceptionProto `protobuf:"bytes,3,opt,name=exception,proto3" json:"exception,omitempty"`
	// contains filtered or unexported fields
}

type StatusProto_ExceptionProto struct {

	// the class name of the exception
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the list of arguments given to the exception constructor.
	Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// the exception traceback stacks
	Stacks []string `protobuf:"bytes,3,rep,name=stacks,proto3" json:"stacks,omitempty"`
	// the name of the executor bind to that Executor (if applicable)
	Executor string `protobuf:"bytes,4,opt,name=executor,proto3" json:"executor,omitempty"`
	// contains filtered or unexported fields
}

type StatusProto_StatusCode int32

type UnimplementedJinaDataRequestRPCServer struct {
}

type UnimplementedJinaDiscoverEndpointsRPCServer struct {
}

type UnimplementedJinaExecutorRestoreProgressServer struct {
}

type UnimplementedJinaExecutorRestoreServer struct {
}

type UnimplementedJinaExecutorSnapshotProgressServer struct {
}

type UnimplementedJinaExecutorSnapshotServer struct {
}

type UnimplementedJinaGatewayDryRunRPCServer struct {
}

type UnimplementedJinaInfoRPCServer struct {
}

type UnimplementedJinaRPCServer struct {
}

type UnimplementedJinaSingleDataRequestRPCServer struct {
}

type UnimplementedJinaSingleDocumentRequestRPCServer struct {
}

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

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

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

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

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

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

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

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

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

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

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