jina

package
v0.0.0-...-2c5e70e Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 12, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	JinaDataRequestRPC_ProcessData_FullMethodName = "/jina.JinaDataRequestRPC/process_data"
)
View Source 
const (
	JinaDiscoverEndpointsRPC_EndpointDiscovery_FullMethodName = "/jina.JinaDiscoverEndpointsRPC/endpoint_discovery"
)
View Source 
const (
	JinaExecutorRestoreProgress_RestoreStatus_FullMethodName = "/jina.JinaExecutorRestoreProgress/restore_status"
)
View Source 
const (
	JinaExecutorRestore_Restore_FullMethodName = "/jina.JinaExecutorRestore/restore"
)
View Source 
const (
	JinaExecutorSnapshotProgress_SnapshotStatus_FullMethodName = "/jina.JinaExecutorSnapshotProgress/snapshot_status"
)
View Source 
const (
	JinaExecutorSnapshot_Snapshot_FullMethodName = "/jina.JinaExecutorSnapshot/snapshot"
)
View Source 
const (
	JinaGatewayDryRunRPC_DryRun_FullMethodName = "/jina.JinaGatewayDryRunRPC/dry_run"
)
View Source 
const (
	JinaInfoRPC_XStatus_FullMethodName = "/jina.JinaInfoRPC/_status"
)
View Source 
const (
	JinaRPC_Call_FullMethodName = "/jina.JinaRPC/Call"
)
View Source 
const (
	JinaSingleDataRequestRPC_ProcessSingleData_FullMethodName = "/jina.JinaSingleDataRequestRPC/process_single_data"
)
View Source 
const (
	JinaSingleDocumentRequestRPC_StreamDoc_FullMethodName = "/jina.JinaSingleDocumentRequestRPC/stream_doc"
)

Variables

View Source 
var (
	StatusProto_StatusCode_name = map[int32]string{
		0: "SUCCESS",
		1: "ERROR",
	}
	StatusProto_StatusCode_value = map[string]int32{
		"SUCCESS": 0,
		"ERROR":   1,
	}
)

Enum value maps for StatusProto_StatusCode.

View Source 
var (
	SnapshotStatusProto_Status_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "QUEUED",
		2: "SCHEDULED",
		3: "RUNNING",
		4: "SUCCEEDED",
		5: "FAILED",
		6: "NOT_FOUND",
	}
	SnapshotStatusProto_Status_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"QUEUED":            1,
		"SCHEDULED":         2,
		"RUNNING":           3,
		"SUCCEEDED":         4,
		"FAILED":            5,
		"NOT_FOUND":         6,
	}
)

Enum value maps for SnapshotStatusProto_Status.

View Source 
var (
	RestoreSnapshotStatusProto_Status_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "RUNNING",
		2: "SUCCEEDED",
		3: "FAILED",
		6: "NOT_FOUND",
	}
	RestoreSnapshotStatusProto_Status_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"RUNNING":           1,
		"SUCCEEDED":         2,
		"FAILED":            3,
		"NOT_FOUND":         6,
	}
)

Enum value maps for RestoreSnapshotStatusProto_Status.

View Source 
var File_jina_proto protoreflect.FileDescriptor
View Source 
var JinaDataRequestRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaDataRequestRPC",
	HandlerType: (*JinaDataRequestRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "process_data",
			Handler:    _JinaDataRequestRPC_ProcessData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jina.proto",
}

JinaDataRequestRPC_ServiceDesc is the grpc.ServiceDesc for JinaDataRequestRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var JinaDiscoverEndpointsRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaDiscoverEndpointsRPC",
	HandlerType: (*JinaDiscoverEndpointsRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "endpoint_discovery",
			Handler:    _JinaDiscoverEndpointsRPC_EndpointDiscovery_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jina.proto",
}

JinaDiscoverEndpointsRPC_ServiceDesc is the grpc.ServiceDesc for JinaDiscoverEndpointsRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var JinaExecutorRestoreProgress_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaExecutorRestoreProgress",
	HandlerType: (*JinaExecutorRestoreProgressServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "restore_status",
			Handler:    _JinaExecutorRestoreProgress_RestoreStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jina.proto",
}

JinaExecutorRestoreProgress_ServiceDesc is the grpc.ServiceDesc for JinaExecutorRestoreProgress service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var JinaExecutorRestore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaExecutorRestore",
	HandlerType: (*JinaExecutorRestoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "restore",
			Handler:    _JinaExecutorRestore_Restore_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jina.proto",
}

JinaExecutorRestore_ServiceDesc is the grpc.ServiceDesc for JinaExecutorRestore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var JinaExecutorSnapshotProgress_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaExecutorSnapshotProgress",
	HandlerType: (*JinaExecutorSnapshotProgressServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "snapshot_status",
			Handler:    _JinaExecutorSnapshotProgress_SnapshotStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jina.proto",
}

JinaExecutorSnapshotProgress_ServiceDesc is the grpc.ServiceDesc for JinaExecutorSnapshotProgress service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var JinaExecutorSnapshot_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaExecutorSnapshot",
	HandlerType: (*JinaExecutorSnapshotServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "snapshot",
			Handler:    _JinaExecutorSnapshot_Snapshot_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jina.proto",
}

JinaExecutorSnapshot_ServiceDesc is the grpc.ServiceDesc for JinaExecutorSnapshot service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var JinaGatewayDryRunRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaGatewayDryRunRPC",
	HandlerType: (*JinaGatewayDryRunRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "dry_run",
			Handler:    _JinaGatewayDryRunRPC_DryRun_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jina.proto",
}

JinaGatewayDryRunRPC_ServiceDesc is the grpc.ServiceDesc for JinaGatewayDryRunRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var JinaInfoRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaInfoRPC",
	HandlerType: (*JinaInfoRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "_status",
			Handler:    _JinaInfoRPC_XStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jina.proto",
}

JinaInfoRPC_ServiceDesc is the grpc.ServiceDesc for JinaInfoRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var JinaRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaRPC",
	HandlerType: (*JinaRPCServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Call",
			Handler:       _JinaRPC_Call_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "jina.proto",
}

JinaRPC_ServiceDesc is the grpc.ServiceDesc for JinaRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var JinaSingleDataRequestRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaSingleDataRequestRPC",
	HandlerType: (*JinaSingleDataRequestRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "process_single_data",
			Handler:    _JinaSingleDataRequestRPC_ProcessSingleData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jina.proto",
}

JinaSingleDataRequestRPC_ServiceDesc is the grpc.ServiceDesc for JinaSingleDataRequestRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var JinaSingleDocumentRequestRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jina.JinaSingleDocumentRequestRPC",
	HandlerType: (*JinaSingleDocumentRequestRPCServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "stream_doc",
			Handler:       _JinaSingleDocumentRequestRPC_StreamDoc_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "jina.proto",
}

JinaSingleDocumentRequestRPC_ServiceDesc is the grpc.ServiceDesc for JinaSingleDocumentRequestRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterJinaDataRequestRPCServer 

func RegisterJinaDataRequestRPCServer(s grpc.ServiceRegistrar, srv JinaDataRequestRPCServer)

func RegisterJinaDiscoverEndpointsRPCServer 

func RegisterJinaDiscoverEndpointsRPCServer(s grpc.ServiceRegistrar, srv JinaDiscoverEndpointsRPCServer)

func RegisterJinaExecutorRestoreProgressServer 

func RegisterJinaExecutorRestoreProgressServer(s grpc.ServiceRegistrar, srv JinaExecutorRestoreProgressServer)

func RegisterJinaExecutorRestoreServer 

func RegisterJinaExecutorRestoreServer(s grpc.ServiceRegistrar, srv JinaExecutorRestoreServer)

func RegisterJinaExecutorSnapshotProgressServer 

func RegisterJinaExecutorSnapshotProgressServer(s grpc.ServiceRegistrar, srv JinaExecutorSnapshotProgressServer)

func RegisterJinaExecutorSnapshotServer 

func RegisterJinaExecutorSnapshotServer(s grpc.ServiceRegistrar, srv JinaExecutorSnapshotServer)

func RegisterJinaGatewayDryRunRPCServer 

func RegisterJinaGatewayDryRunRPCServer(s grpc.ServiceRegistrar, srv JinaGatewayDryRunRPCServer)

func RegisterJinaInfoRPCServer 

func RegisterJinaInfoRPCServer(s grpc.ServiceRegistrar, srv JinaInfoRPCServer)

func RegisterJinaRPCServer 

func RegisterJinaRPCServer(s grpc.ServiceRegistrar, srv JinaRPCServer)

func RegisterJinaSingleDataRequestRPCServer 

func RegisterJinaSingleDataRequestRPCServer(s grpc.ServiceRegistrar, srv JinaSingleDataRequestRPCServer)

func RegisterJinaSingleDocumentRequestRPCServer 

func RegisterJinaSingleDocumentRequestRPCServer(s grpc.ServiceRegistrar, srv JinaSingleDocumentRequestRPCServer)

Types

type DataRequestListProto 

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

* Represents a list of data requests This should be replaced by streaming

func (*DataRequestListProto) Descriptor deprecated 

func (*DataRequestListProto) Descriptor() ([]byte, []int)

Deprecated: Use DataRequestListProto.ProtoReflect.Descriptor instead.

func (*DataRequestListProto) GetRequests 

func (x *DataRequestListProto) GetRequests() []*DataRequestProto

func (*DataRequestListProto) ProtoMessage 

func (*DataRequestListProto) ProtoMessage()

func (*DataRequestListProto) ProtoReflect 

func (x *DataRequestListProto) ProtoReflect() protoreflect.Message

func (*DataRequestListProto) Reset 

func (x *DataRequestListProto) Reset()

func (*DataRequestListProto) String 

func (x *DataRequestListProto) String() string

type DataRequestProto 

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
}

* Represents a DataRequest

func (*DataRequestProto) Descriptor deprecated 

func (*DataRequestProto) Descriptor() ([]byte, []int)

Deprecated: Use DataRequestProto.ProtoReflect.Descriptor instead.

func (*DataRequestProto) GetData 

func (x *DataRequestProto) GetData() *DataRequestProto_DataContentProto

func (*DataRequestProto) GetHeader 

func (x *DataRequestProto) GetHeader() *HeaderProto

func (*DataRequestProto) GetParameters 

func (x *DataRequestProto) GetParameters() *structpb.Struct

func (*DataRequestProto) GetRoutes 

func (x *DataRequestProto) GetRoutes() []*RouteProto

func (*DataRequestProto) MarshalJSON 

func (x *DataRequestProto) MarshalJSON() ([]byte, error)

Custom JSON marshalling for DataRequestProto

func (*DataRequestProto) ProtoMessage 

func (*DataRequestProto) ProtoMessage()

func (*DataRequestProto) ProtoReflect 

func (x *DataRequestProto) ProtoReflect() protoreflect.Message

func (*DataRequestProto) Reset 

func (x *DataRequestProto) Reset()

func (*DataRequestProto) String 

func (x *DataRequestProto) String() string

func (*DataRequestProto) UnmarshalJSON 

func (x *DataRequestProto) UnmarshalJSON(data []byte) error

Custom JSON unmarshalling for DataRequestProto

type DataRequestProtoWoData 

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
}

func (*DataRequestProtoWoData) Descriptor deprecated 

func (*DataRequestProtoWoData) Descriptor() ([]byte, []int)

Deprecated: Use DataRequestProtoWoData.ProtoReflect.Descriptor instead.

func (*DataRequestProtoWoData) GetHeader 

func (x *DataRequestProtoWoData) GetHeader() *HeaderProto

func (*DataRequestProtoWoData) GetParameters 

func (x *DataRequestProtoWoData) GetParameters() *structpb.Struct

func (*DataRequestProtoWoData) GetRoutes 

func (x *DataRequestProtoWoData) GetRoutes() []*RouteProto

func (*DataRequestProtoWoData) ProtoMessage 

func (*DataRequestProtoWoData) ProtoMessage()

func (*DataRequestProtoWoData) ProtoReflect 

func (x *DataRequestProtoWoData) ProtoReflect() protoreflect.Message

func (*DataRequestProtoWoData) Reset 

func (x *DataRequestProtoWoData) Reset()

func (*DataRequestProtoWoData) String 

func (x *DataRequestProtoWoData) String() string

type DataRequestProto_DataContentProto 

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
}

func (*DataRequestProto_DataContentProto) Descriptor deprecated 

func (*DataRequestProto_DataContentProto) Descriptor() ([]byte, []int)

Deprecated: Use DataRequestProto_DataContentProto.ProtoReflect.Descriptor instead.

func (*DataRequestProto_DataContentProto) GetDocs 

func (x *DataRequestProto_DataContentProto) GetDocs() *docarray.DocumentArrayProto

func (*DataRequestProto_DataContentProto) GetDocsBytes 

func (x *DataRequestProto_DataContentProto) GetDocsBytes() []byte

func (*DataRequestProto_DataContentProto) GetDocuments 

func (m *DataRequestProto_DataContentProto) GetDocuments() isDataRequestProto_DataContentProto_Documents

func (*DataRequestProto_DataContentProto) ProtoMessage 

func (*DataRequestProto_DataContentProto) ProtoMessage()

func (*DataRequestProto_DataContentProto) ProtoReflect 

func (x *DataRequestProto_DataContentProto) ProtoReflect() protoreflect.Message

func (*DataRequestProto_DataContentProto) Reset 

func (x *DataRequestProto_DataContentProto) Reset()

func (*DataRequestProto_DataContentProto) String 

func (x *DataRequestProto_DataContentProto) String() string

type DataRequestProto_DataContentProto_Docs 

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 

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 

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
}

* Represents the set of Endpoints exposed by an Executor

func (*EndpointsProto) Descriptor deprecated 

func (*EndpointsProto) Descriptor() ([]byte, []int)

Deprecated: Use EndpointsProto.ProtoReflect.Descriptor instead.

func (*EndpointsProto) GetEndpoints 

func (x *EndpointsProto) GetEndpoints() []string

func (*EndpointsProto) GetSchemas 

func (x *EndpointsProto) GetSchemas() *structpb.Struct

func (*EndpointsProto) GetWriteEndpoints 

func (x *EndpointsProto) GetWriteEndpoints() []string

func (*EndpointsProto) ProtoMessage 

func (*EndpointsProto) ProtoMessage()

func (*EndpointsProto) ProtoReflect 

func (x *EndpointsProto) ProtoReflect() protoreflect.Message

func (*EndpointsProto) Reset 

func (x *EndpointsProto) Reset()

func (*EndpointsProto) String 

func (x *EndpointsProto) String() string

type HeaderProto 

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
}

* Represents a Header. - The header's content will be defined by the user request. - It will be copied to the envelope.header - In-flow operations will modify the envelope.header - While returning, copy envelope.header back to request.header

func (*HeaderProto) Descriptor deprecated 

func (*HeaderProto) Descriptor() ([]byte, []int)

Deprecated: Use HeaderProto.ProtoReflect.Descriptor instead.

func (*HeaderProto) GetExecEndpoint 

func (x *HeaderProto) GetExecEndpoint() string

func (*HeaderProto) GetRequestId 

func (x *HeaderProto) GetRequestId() string

func (*HeaderProto) GetStatus 

func (x *HeaderProto) GetStatus() *StatusProto

func (*HeaderProto) GetTargetExecutor 

func (x *HeaderProto) GetTargetExecutor() string

func (*HeaderProto) GetTimeout 

func (x *HeaderProto) GetTimeout() uint32

func (*HeaderProto) ProtoMessage 

func (*HeaderProto) ProtoMessage()

func (*HeaderProto) ProtoReflect 

func (x *HeaderProto) ProtoReflect() protoreflect.Message

func (*HeaderProto) Reset 

func (x *HeaderProto) Reset()

func (*HeaderProto) String 

func (x *HeaderProto) String() string

type JinaDataRequestRPCClient 

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

JinaDataRequestRPCClient is the client API for JinaDataRequestRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaDataRequestRPCClient 

func NewJinaDataRequestRPCClient(cc grpc.ClientConnInterface) JinaDataRequestRPCClient

type JinaDataRequestRPCServer 

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

JinaDataRequestRPCServer is the server API for JinaDataRequestRPC service. All implementations must embed UnimplementedJinaDataRequestRPCServer for forward compatibility

type JinaDiscoverEndpointsRPCClient 

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

JinaDiscoverEndpointsRPCClient is the client API for JinaDiscoverEndpointsRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaDiscoverEndpointsRPCClient 

func NewJinaDiscoverEndpointsRPCClient(cc grpc.ClientConnInterface) JinaDiscoverEndpointsRPCClient

type JinaDiscoverEndpointsRPCServer 

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

JinaDiscoverEndpointsRPCServer is the server API for JinaDiscoverEndpointsRPC service. All implementations must embed UnimplementedJinaDiscoverEndpointsRPCServer for forward compatibility

type JinaExecutorRestoreClient 

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

JinaExecutorRestoreClient is the client API for JinaExecutorRestore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaExecutorRestoreClient 

func NewJinaExecutorRestoreClient(cc grpc.ClientConnInterface) JinaExecutorRestoreClient

type JinaExecutorRestoreProgressClient 

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

JinaExecutorRestoreProgressClient is the client API for JinaExecutorRestoreProgress service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaExecutorRestoreProgressClient 

func NewJinaExecutorRestoreProgressClient(cc grpc.ClientConnInterface) JinaExecutorRestoreProgressClient

type JinaExecutorRestoreProgressServer 

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

JinaExecutorRestoreProgressServer is the server API for JinaExecutorRestoreProgress service. All implementations must embed UnimplementedJinaExecutorRestoreProgressServer for forward compatibility

type JinaExecutorRestoreServer 

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

JinaExecutorRestoreServer is the server API for JinaExecutorRestore service. All implementations must embed UnimplementedJinaExecutorRestoreServer for forward compatibility

type JinaExecutorSnapshotClient 

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

JinaExecutorSnapshotClient is the client API for JinaExecutorSnapshot service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaExecutorSnapshotClient 

func NewJinaExecutorSnapshotClient(cc grpc.ClientConnInterface) JinaExecutorSnapshotClient

type JinaExecutorSnapshotProgressClient 

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

JinaExecutorSnapshotProgressClient is the client API for JinaExecutorSnapshotProgress service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaExecutorSnapshotProgressClient 

func NewJinaExecutorSnapshotProgressClient(cc grpc.ClientConnInterface) JinaExecutorSnapshotProgressClient

type JinaExecutorSnapshotProgressServer 

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

JinaExecutorSnapshotProgressServer is the server API for JinaExecutorSnapshotProgress service. All implementations must embed UnimplementedJinaExecutorSnapshotProgressServer for forward compatibility

type JinaExecutorSnapshotServer 

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

JinaExecutorSnapshotServer is the server API for JinaExecutorSnapshot service. All implementations must embed UnimplementedJinaExecutorSnapshotServer for forward compatibility

type JinaGatewayDryRunRPCClient 

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

JinaGatewayDryRunRPCClient is the client API for JinaGatewayDryRunRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaGatewayDryRunRPCClient 

func NewJinaGatewayDryRunRPCClient(cc grpc.ClientConnInterface) JinaGatewayDryRunRPCClient

type JinaGatewayDryRunRPCServer 

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

JinaGatewayDryRunRPCServer is the server API for JinaGatewayDryRunRPC service. All implementations must embed UnimplementedJinaGatewayDryRunRPCServer for forward compatibility

type JinaInfoProto 

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
}

func (*JinaInfoProto) Descriptor deprecated 

func (*JinaInfoProto) Descriptor() ([]byte, []int)

Deprecated: Use JinaInfoProto.ProtoReflect.Descriptor instead.

func (*JinaInfoProto) GetEnvs 

func (x *JinaInfoProto) GetEnvs() map[string]string

func (*JinaInfoProto) GetJina 

func (x *JinaInfoProto) GetJina() map[string]string

func (*JinaInfoProto) ProtoMessage 

func (*JinaInfoProto) ProtoMessage()

func (*JinaInfoProto) ProtoReflect 

func (x *JinaInfoProto) ProtoReflect() protoreflect.Message

func (*JinaInfoProto) Reset 

func (x *JinaInfoProto) Reset()

func (*JinaInfoProto) String 

func (x *JinaInfoProto) String() string

type JinaInfoRPCClient 

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

JinaInfoRPCClient is the client API for JinaInfoRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaInfoRPCClient 

func NewJinaInfoRPCClient(cc grpc.ClientConnInterface) JinaInfoRPCClient

type JinaInfoRPCServer 

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

JinaInfoRPCServer is the server API for JinaInfoRPC service. All implementations must embed UnimplementedJinaInfoRPCServer for forward compatibility

type JinaRPCClient 

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)
}

JinaRPCClient is the client API for JinaRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaRPCClient 

func NewJinaRPCClient(cc grpc.ClientConnInterface) JinaRPCClient

type JinaRPCServer 

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
}

JinaRPCServer is the server API for JinaRPC service. All implementations must embed UnimplementedJinaRPCServer for forward compatibility

type JinaRPC_CallClient 

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

type JinaRPC_CallServer 

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

type JinaSingleDataRequestRPCClient 

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

JinaSingleDataRequestRPCClient is the client API for JinaSingleDataRequestRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaSingleDataRequestRPCClient 

func NewJinaSingleDataRequestRPCClient(cc grpc.ClientConnInterface) JinaSingleDataRequestRPCClient

type JinaSingleDataRequestRPCServer 

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

JinaSingleDataRequestRPCServer is the server API for JinaSingleDataRequestRPC service. All implementations must embed UnimplementedJinaSingleDataRequestRPCServer for forward compatibility

type JinaSingleDocumentRequestRPCClient 

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

JinaSingleDocumentRequestRPCClient is the client API for JinaSingleDocumentRequestRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJinaSingleDocumentRequestRPCClient 

func NewJinaSingleDocumentRequestRPCClient(cc grpc.ClientConnInterface) JinaSingleDocumentRequestRPCClient

type JinaSingleDocumentRequestRPCServer 

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

JinaSingleDocumentRequestRPCServer is the server API for JinaSingleDocumentRequestRPC service. All implementations must embed UnimplementedJinaSingleDocumentRequestRPCServer for forward compatibility

type JinaSingleDocumentRequestRPC_StreamDocClient 

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

type JinaSingleDocumentRequestRPC_StreamDocServer 

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

type RelatedEntity 

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
}

* Represents an entity (like an ExecutorRuntime)

func (*RelatedEntity) Descriptor deprecated 

func (*RelatedEntity) Descriptor() ([]byte, []int)

Deprecated: Use RelatedEntity.ProtoReflect.Descriptor instead.

func (*RelatedEntity) GetAddress 

func (x *RelatedEntity) GetAddress() string

func (*RelatedEntity) GetId 

func (x *RelatedEntity) GetId() string

func (*RelatedEntity) GetPort 

func (x *RelatedEntity) GetPort() uint32

func (*RelatedEntity) GetShardId 

func (x *RelatedEntity) GetShardId() uint32

func (*RelatedEntity) ProtoMessage 

func (*RelatedEntity) ProtoMessage()

func (*RelatedEntity) ProtoReflect 

func (x *RelatedEntity) ProtoReflect() protoreflect.Message

func (*RelatedEntity) Reset 

func (x *RelatedEntity) Reset()

func (*RelatedEntity) String 

func (x *RelatedEntity) String() string

type RestoreId 

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

* An ID representation for the Restore Job

func (*RestoreId) Descriptor deprecated 

func (*RestoreId) Descriptor() ([]byte, []int)

Deprecated: Use RestoreId.ProtoReflect.Descriptor instead.

func (*RestoreId) GetValue 

func (x *RestoreId) GetValue() string

func (*RestoreId) ProtoMessage 

func (*RestoreId) ProtoMessage()

func (*RestoreId) ProtoReflect 

func (x *RestoreId) ProtoReflect() protoreflect.Message

func (*RestoreId) Reset 

func (x *RestoreId) Reset()

func (*RestoreId) String 

func (x *RestoreId) String() string

type RestoreSnapshotCommand 

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
}

* Commands to restore an Executor from a snapshot file

func (*RestoreSnapshotCommand) Descriptor deprecated 

func (*RestoreSnapshotCommand) Descriptor() ([]byte, []int)

Deprecated: Use RestoreSnapshotCommand.ProtoReflect.Descriptor instead.

func (*RestoreSnapshotCommand) GetSnapshotFile 

func (x *RestoreSnapshotCommand) GetSnapshotFile() string

func (*RestoreSnapshotCommand) ProtoMessage 

func (*RestoreSnapshotCommand) ProtoMessage()

func (*RestoreSnapshotCommand) ProtoReflect 

func (x *RestoreSnapshotCommand) ProtoReflect() protoreflect.Message

func (*RestoreSnapshotCommand) Reset 

func (x *RestoreSnapshotCommand) Reset()

func (*RestoreSnapshotCommand) String 

func (x *RestoreSnapshotCommand) String() string

type RestoreSnapshotStatusProto 

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
}

* Represents the status of a Restore.

func (*RestoreSnapshotStatusProto) Descriptor deprecated 

func (*RestoreSnapshotStatusProto) Descriptor() ([]byte, []int)

Deprecated: Use RestoreSnapshotStatusProto.ProtoReflect.Descriptor instead.

func (*RestoreSnapshotStatusProto) GetId 

func (x *RestoreSnapshotStatusProto) GetId() *RestoreId

func (*RestoreSnapshotStatusProto) GetStatus 

func (x *RestoreSnapshotStatusProto) GetStatus() RestoreSnapshotStatusProto_Status

func (*RestoreSnapshotStatusProto) ProtoMessage 

func (*RestoreSnapshotStatusProto) ProtoMessage()

func (*RestoreSnapshotStatusProto) ProtoReflect 

func (x *RestoreSnapshotStatusProto) ProtoReflect() protoreflect.Message

func (*RestoreSnapshotStatusProto) Reset 

func (x *RestoreSnapshotStatusProto) Reset()

func (*RestoreSnapshotStatusProto) String 

func (x *RestoreSnapshotStatusProto) String() string

type RestoreSnapshotStatusProto_Status 

type RestoreSnapshotStatusProto_Status int32
const (
	RestoreSnapshotStatusProto_STATE_UNSPECIFIED RestoreSnapshotStatusProto_Status = 0
	RestoreSnapshotStatusProto_RUNNING           RestoreSnapshotStatusProto_Status = 1 // Resource allocation has been successful. Restore Job is RUNNING.
	RestoreSnapshotStatusProto_SUCCEEDED         RestoreSnapshotStatusProto_Status = 2 // Resource Job has finished successfully.
	RestoreSnapshotStatusProto_FAILED            RestoreSnapshotStatusProto_Status = 3 // Resource Job has failed.
	RestoreSnapshotStatusProto_NOT_FOUND         RestoreSnapshotStatusProto_Status = 6 // If the specific restore id is unknown or not found
)

func (RestoreSnapshotStatusProto_Status) Descriptor 

func (RestoreSnapshotStatusProto_Status) Descriptor() protoreflect.EnumDescriptor

func (RestoreSnapshotStatusProto_Status) Enum 

func (x RestoreSnapshotStatusProto_Status) Enum() *RestoreSnapshotStatusProto_Status

func (RestoreSnapshotStatusProto_Status) EnumDescriptor deprecated 

func (RestoreSnapshotStatusProto_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use RestoreSnapshotStatusProto_Status.Descriptor instead.

func (RestoreSnapshotStatusProto_Status) Number 

func (x RestoreSnapshotStatusProto_Status) Number() protoreflect.EnumNumber

func (RestoreSnapshotStatusProto_Status) String 

func (x RestoreSnapshotStatusProto_Status) String() string

func (RestoreSnapshotStatusProto_Status) Type 

func (RestoreSnapshotStatusProto_Status) Type() protoreflect.EnumType

type RouteProto 

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
}

* Represents a the route paths of this message as perceived by the Gateway start_time is set when the Gateway sends a message to a Pod end_time is set when the Gateway receives a message from a Pod thus end_time - start_time includes Executor computation, runtime overhead, serialization and network

func (*RouteProto) Descriptor deprecated 

func (*RouteProto) Descriptor() ([]byte, []int)

Deprecated: Use RouteProto.ProtoReflect.Descriptor instead.

func (*RouteProto) GetEndTime 

func (x *RouteProto) GetEndTime() *timestamppb.Timestamp

func (*RouteProto) GetExecutor 

func (x *RouteProto) GetExecutor() string

func (*RouteProto) GetStartTime 

func (x *RouteProto) GetStartTime() *timestamppb.Timestamp

func (*RouteProto) GetStatus 

func (x *RouteProto) GetStatus() *StatusProto

func (*RouteProto) MarshalJSON 

func (x *RouteProto) MarshalJSON() ([]byte, error)

Custom JSON marshalling for RouteProto

func (*RouteProto) ProtoMessage 

func (*RouteProto) ProtoMessage()

func (*RouteProto) ProtoReflect 

func (x *RouteProto) ProtoReflect() protoreflect.Message

func (*RouteProto) Reset 

func (x *RouteProto) Reset()

func (*RouteProto) String 

func (x *RouteProto) String() string

func (*RouteProto) UnmarshalJSON 

func (x *RouteProto) UnmarshalJSON(data []byte) error

Custom JSON unmarshalling for RouteProto

type SingleDocumentRequestProto 

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
}

* Represents a Single Document DataRequest

func (*SingleDocumentRequestProto) Descriptor deprecated 

func (*SingleDocumentRequestProto) Descriptor() ([]byte, []int)

Deprecated: Use SingleDocumentRequestProto.ProtoReflect.Descriptor instead.

func (*SingleDocumentRequestProto) GetDocument 

func (x *SingleDocumentRequestProto) GetDocument() *docarray.DocumentProto

func (*SingleDocumentRequestProto) GetHeader 

func (x *SingleDocumentRequestProto) GetHeader() *HeaderProto

func (*SingleDocumentRequestProto) GetParameters 

func (x *SingleDocumentRequestProto) GetParameters() *structpb.Struct

func (*SingleDocumentRequestProto) GetRoutes 

func (x *SingleDocumentRequestProto) GetRoutes() []*RouteProto

func (*SingleDocumentRequestProto) ProtoMessage 

func (*SingleDocumentRequestProto) ProtoMessage()

func (*SingleDocumentRequestProto) ProtoReflect 

func (x *SingleDocumentRequestProto) ProtoReflect() protoreflect.Message

func (*SingleDocumentRequestProto) Reset 

func (x *SingleDocumentRequestProto) Reset()

func (*SingleDocumentRequestProto) String 

func (x *SingleDocumentRequestProto) String() string

type SnapshotId 

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

* An ID representation for the Snapshot Job

func (*SnapshotId) Descriptor deprecated 

func (*SnapshotId) Descriptor() ([]byte, []int)

Deprecated: Use SnapshotId.ProtoReflect.Descriptor instead.

func (*SnapshotId) GetValue 

func (x *SnapshotId) GetValue() string

func (*SnapshotId) ProtoMessage 

func (*SnapshotId) ProtoMessage()

func (*SnapshotId) ProtoReflect 

func (x *SnapshotId) ProtoReflect() protoreflect.Message

func (*SnapshotId) Reset 

func (x *SnapshotId) Reset()

func (*SnapshotId) String 

func (x *SnapshotId) String() string

type SnapshotStatusProto 

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
}

* Represents the status of a Snapshot.

func (*SnapshotStatusProto) Descriptor deprecated 

func (*SnapshotStatusProto) Descriptor() ([]byte, []int)

Deprecated: Use SnapshotStatusProto.ProtoReflect.Descriptor instead.

func (*SnapshotStatusProto) GetId 

func (x *SnapshotStatusProto) GetId() *SnapshotId

func (*SnapshotStatusProto) GetSnapshotFile 

func (x *SnapshotStatusProto) GetSnapshotFile() string

func (*SnapshotStatusProto) GetStatus 

func (x *SnapshotStatusProto) GetStatus() SnapshotStatusProto_Status

func (*SnapshotStatusProto) ProtoMessage 

func (*SnapshotStatusProto) ProtoMessage()

func (*SnapshotStatusProto) ProtoReflect 

func (x *SnapshotStatusProto) ProtoReflect() protoreflect.Message

func (*SnapshotStatusProto) Reset 

func (x *SnapshotStatusProto) Reset()

func (*SnapshotStatusProto) String 

func (x *SnapshotStatusProto) String() string

type SnapshotStatusProto_Status 

type SnapshotStatusProto_Status int32
const (
	SnapshotStatusProto_STATE_UNSPECIFIED SnapshotStatusProto_Status = 0
	SnapshotStatusProto_QUEUED            SnapshotStatusProto_Status = 1 // Snapshot Job is admitted (validated and persisted) and waiting for resources.
	SnapshotStatusProto_SCHEDULED         SnapshotStatusProto_Status = 2 // Snapshot Job is scheduled to run as soon as resource allocation is ready.
	SnapshotStatusProto_RUNNING           SnapshotStatusProto_Status = 3 // Resource allocation has been successful. Snapshot Job is RUNNING.
	SnapshotStatusProto_SUCCEEDED         SnapshotStatusProto_Status = 4 // Snapshot Job has finished successfully.
	SnapshotStatusProto_FAILED            SnapshotStatusProto_Status = 5 // Snapshot Job has failed.
	SnapshotStatusProto_NOT_FOUND         SnapshotStatusProto_Status = 6 // If the specific snapshot id is unknown or not found
)

func (SnapshotStatusProto_Status) Descriptor 

func (SnapshotStatusProto_Status) Descriptor() protoreflect.EnumDescriptor

func (SnapshotStatusProto_Status) Enum 

func (x SnapshotStatusProto_Status) Enum() *SnapshotStatusProto_Status

func (SnapshotStatusProto_Status) EnumDescriptor deprecated 

func (SnapshotStatusProto_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use SnapshotStatusProto_Status.Descriptor instead.

func (SnapshotStatusProto_Status) Number 

func (x SnapshotStatusProto_Status) Number() protoreflect.EnumNumber

func (SnapshotStatusProto_Status) String 

func (x SnapshotStatusProto_Status) String() string

func (SnapshotStatusProto_Status) Type 

func (SnapshotStatusProto_Status) Type() protoreflect.EnumType

type StatusProto 

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
}

* Represents a Status

func (*StatusProto) Descriptor deprecated 

func (*StatusProto) Descriptor() ([]byte, []int)

Deprecated: Use StatusProto.ProtoReflect.Descriptor instead.

func (*StatusProto) GetCode 

func (x *StatusProto) GetCode() StatusProto_StatusCode

func (*StatusProto) GetDescription 

func (x *StatusProto) GetDescription() string

func (*StatusProto) GetException 

func (x *StatusProto) GetException() *StatusProto_ExceptionProto

func (*StatusProto) ProtoMessage 

func (*StatusProto) ProtoMessage()

func (*StatusProto) ProtoReflect 

func (x *StatusProto) ProtoReflect() protoreflect.Message

func (*StatusProto) Reset 

func (x *StatusProto) Reset()

func (*StatusProto) String 

func (x *StatusProto) String() string

type StatusProto_ExceptionProto 

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
}

func (*StatusProto_ExceptionProto) Descriptor deprecated 

func (*StatusProto_ExceptionProto) Descriptor() ([]byte, []int)

Deprecated: Use StatusProto_ExceptionProto.ProtoReflect.Descriptor instead.

func (*StatusProto_ExceptionProto) GetArgs 

func (x *StatusProto_ExceptionProto) GetArgs() []string

func (*StatusProto_ExceptionProto) GetExecutor 

func (x *StatusProto_ExceptionProto) GetExecutor() string

func (*StatusProto_ExceptionProto) GetName 

func (x *StatusProto_ExceptionProto) GetName() string

func (*StatusProto_ExceptionProto) GetStacks 

func (x *StatusProto_ExceptionProto) GetStacks() []string

func (*StatusProto_ExceptionProto) ProtoMessage 

func (*StatusProto_ExceptionProto) ProtoMessage()

func (*StatusProto_ExceptionProto) ProtoReflect 

func (x *StatusProto_ExceptionProto) ProtoReflect() protoreflect.Message

func (*StatusProto_ExceptionProto) Reset 

func (x *StatusProto_ExceptionProto) Reset()

func (*StatusProto_ExceptionProto) String 

func (x *StatusProto_ExceptionProto) String() string

type StatusProto_StatusCode 

type StatusProto_StatusCode int32
const (
	StatusProto_SUCCESS StatusProto_StatusCode = 0 // success
	StatusProto_ERROR   StatusProto_StatusCode = 1 // error
)

func (StatusProto_StatusCode) Descriptor 

func (StatusProto_StatusCode) Descriptor() protoreflect.EnumDescriptor

func (StatusProto_StatusCode) Enum 

func (x StatusProto_StatusCode) Enum() *StatusProto_StatusCode

func (StatusProto_StatusCode) EnumDescriptor deprecated 

func (StatusProto_StatusCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use StatusProto_StatusCode.Descriptor instead.

func (StatusProto_StatusCode) Number 

func (x StatusProto_StatusCode) Number() protoreflect.EnumNumber

func (StatusProto_StatusCode) String 

func (x StatusProto_StatusCode) String() string

func (StatusProto_StatusCode) Type 

func (StatusProto_StatusCode) Type() protoreflect.EnumType

type UnimplementedJinaDataRequestRPCServer 

type UnimplementedJinaDataRequestRPCServer struct {
}

UnimplementedJinaDataRequestRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaDataRequestRPCServer) ProcessData 

func (UnimplementedJinaDataRequestRPCServer) ProcessData(context.Context, *DataRequestListProto) (*DataRequestProto, error)

type UnimplementedJinaDiscoverEndpointsRPCServer 

type UnimplementedJinaDiscoverEndpointsRPCServer struct {
}

UnimplementedJinaDiscoverEndpointsRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaDiscoverEndpointsRPCServer) EndpointDiscovery 

func (UnimplementedJinaDiscoverEndpointsRPCServer) EndpointDiscovery(context.Context, *emptypb.Empty) (*EndpointsProto, error)

type UnimplementedJinaExecutorRestoreProgressServer 

type UnimplementedJinaExecutorRestoreProgressServer struct {
}

UnimplementedJinaExecutorRestoreProgressServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaExecutorRestoreProgressServer) RestoreStatus 

func (UnimplementedJinaExecutorRestoreProgressServer) RestoreStatus(context.Context, *RestoreId) (*RestoreSnapshotStatusProto, error)

type UnimplementedJinaExecutorRestoreServer 

type UnimplementedJinaExecutorRestoreServer struct {
}

UnimplementedJinaExecutorRestoreServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaExecutorRestoreServer) Restore 

func (UnimplementedJinaExecutorRestoreServer) Restore(context.Context, *RestoreSnapshotCommand) (*RestoreSnapshotStatusProto, error)

type UnimplementedJinaExecutorSnapshotProgressServer 

type UnimplementedJinaExecutorSnapshotProgressServer struct {
}

UnimplementedJinaExecutorSnapshotProgressServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaExecutorSnapshotProgressServer) SnapshotStatus 

func (UnimplementedJinaExecutorSnapshotProgressServer) SnapshotStatus(context.Context, *SnapshotId) (*SnapshotStatusProto, error)

type UnimplementedJinaExecutorSnapshotServer 

type UnimplementedJinaExecutorSnapshotServer struct {
}

UnimplementedJinaExecutorSnapshotServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaExecutorSnapshotServer) Snapshot 

func (UnimplementedJinaExecutorSnapshotServer) Snapshot(context.Context, *emptypb.Empty) (*SnapshotStatusProto, error)

type UnimplementedJinaGatewayDryRunRPCServer 

type UnimplementedJinaGatewayDryRunRPCServer struct {
}

UnimplementedJinaGatewayDryRunRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaGatewayDryRunRPCServer) DryRun 

func (UnimplementedJinaGatewayDryRunRPCServer) DryRun(context.Context, *emptypb.Empty) (*StatusProto, error)

type UnimplementedJinaInfoRPCServer 

type UnimplementedJinaInfoRPCServer struct {
}

UnimplementedJinaInfoRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaInfoRPCServer) XStatus 

func (UnimplementedJinaInfoRPCServer) XStatus(context.Context, *emptypb.Empty) (*JinaInfoProto, error)

type UnimplementedJinaRPCServer 

type UnimplementedJinaRPCServer struct {
}

UnimplementedJinaRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaRPCServer) Call 

func (UnimplementedJinaRPCServer) Call(JinaRPC_CallServer) error

type UnimplementedJinaSingleDataRequestRPCServer 

type UnimplementedJinaSingleDataRequestRPCServer struct {
}

UnimplementedJinaSingleDataRequestRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaSingleDataRequestRPCServer) ProcessSingleData 

func (UnimplementedJinaSingleDataRequestRPCServer) ProcessSingleData(context.Context, *DataRequestProto) (*DataRequestProto, error)

type UnimplementedJinaSingleDocumentRequestRPCServer 

type UnimplementedJinaSingleDocumentRequestRPCServer struct {
}

UnimplementedJinaSingleDocumentRequestRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedJinaSingleDocumentRequestRPCServer) StreamDoc 

func (UnimplementedJinaSingleDocumentRequestRPCServer) StreamDoc(*SingleDocumentRequestProto, JinaSingleDocumentRequestRPC_StreamDocServer) error

type UnsafeJinaDataRequestRPCServer 

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

UnsafeJinaDataRequestRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaDataRequestRPCServer will result in compilation errors.

type UnsafeJinaDiscoverEndpointsRPCServer 

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

UnsafeJinaDiscoverEndpointsRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaDiscoverEndpointsRPCServer will result in compilation errors.

type UnsafeJinaExecutorRestoreProgressServer 

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

UnsafeJinaExecutorRestoreProgressServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaExecutorRestoreProgressServer will result in compilation errors.

type UnsafeJinaExecutorRestoreServer 

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

UnsafeJinaExecutorRestoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaExecutorRestoreServer will result in compilation errors.

type UnsafeJinaExecutorSnapshotProgressServer 

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

UnsafeJinaExecutorSnapshotProgressServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaExecutorSnapshotProgressServer will result in compilation errors.

type UnsafeJinaExecutorSnapshotServer 

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

UnsafeJinaExecutorSnapshotServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaExecutorSnapshotServer will result in compilation errors.

type UnsafeJinaGatewayDryRunRPCServer 

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

UnsafeJinaGatewayDryRunRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaGatewayDryRunRPCServer will result in compilation errors.

type UnsafeJinaInfoRPCServer 

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

UnsafeJinaInfoRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaInfoRPCServer will result in compilation errors.

type UnsafeJinaRPCServer 

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

UnsafeJinaRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaRPCServer will result in compilation errors.

type UnsafeJinaSingleDataRequestRPCServer 

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

UnsafeJinaSingleDataRequestRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaSingleDataRequestRPCServer will result in compilation errors.

type UnsafeJinaSingleDocumentRequestRPCServer 

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

UnsafeJinaSingleDocumentRequestRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JinaSingleDocumentRequestRPCServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.