Documentation ¶
Index ¶
- Constants
- type GRPCIndexServer
- type GRPCIndexService
- func (s *GRPCIndexService) AddDocuments(ctx context.Context, req *proto.AddDocumentsRequest) (*proto.AddDocumentsResponse, error)
- func (s *GRPCIndexService) Cluster(ctx context.Context, req *proto.ClusterRequest) (*proto.ClusterResponse, error)
- func (s *GRPCIndexService) CreateIndex(ctx context.Context, req *proto.CreateIndexRequest) (*proto.CreateIndexResponse, error)
- func (s *GRPCIndexService) DeleteDocuments(ctx context.Context, req *proto.DeleteDocumentsRequest) (*proto.DeleteDocumentsResponse, error)
- func (s *GRPCIndexService) DeleteIndex(ctx context.Context, req *proto.DeleteIndexRequest) (*proto.DeleteIndexResponse, error)
- func (s *GRPCIndexService) LivenessCheck(ctx context.Context, req *proto.LivenessCheckRequest) (*proto.LivenessCheckResponse, error)
- func (s *GRPCIndexService) Metrics(ctx context.Context, req *proto.MetricsRequest) (*proto.MetricsResponse, error)
- func (s *GRPCIndexService) ReadinessCheck(ctx context.Context, req *proto.ReadinessCheckRequest) (*proto.ReadinessCheckResponse, error)
- func (s *GRPCIndexService) Search(ctx context.Context, req *proto.SearchRequest) (*proto.SearchResponse, error)
- type HTTPIndexServer
- type IndexService
- func (s *IndexService) AddDocuments(req *proto.AddDocumentsRequest) (*proto.AddDocumentsResponse, error)
- func (s *IndexService) Cluster(req *proto.ClusterRequest) (*proto.ClusterResponse, error)
- func (s *IndexService) CreateIndex(req *proto.CreateIndexRequest) (*proto.CreateIndexResponse, error)
- func (s *IndexService) DeleteDocuments(req *proto.DeleteDocumentsRequest) (*proto.DeleteDocumentsResponse, error)
- func (s *IndexService) DeleteIndex(req *proto.DeleteIndexRequest) (*proto.DeleteIndexResponse, error)
- func (s *IndexService) Search(req *proto.SearchRequest) (*proto.SearchResponse, error)
- func (s *IndexService) Start() error
- func (s *IndexService) Stop() error
- type Marshaler
- func (m *Marshaler) ContentType(v interface{}) string
- func (m *Marshaler) Delimiter() []byte
- func (m *Marshaler) Marshal(v interface{}) ([]byte, error)
- func (m *Marshaler) NewDecoder(r io.Reader) runtime.Decoder
- func (m *Marshaler) NewEncoder(w io.Writer) runtime.Encoder
- func (m *Marshaler) Unmarshal(data []byte, v interface{}) error
Constants ¶
View Source
const CorsMaxAge = 12 * time.Hour
View Source
const DefaultContentType = "application/json"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GRPCIndexServer ¶
type GRPCIndexServer struct {
// contains filtered or unexported fields
}
func NewGRPCIndexServer ¶
func NewGRPCIndexServer(grpcAddress string, certificateFile string, keyFile string, commonName string, indexService proto.IndexServer, logger *zap.Logger) (*GRPCIndexServer, error)
func (*GRPCIndexServer) Start ¶
func (s *GRPCIndexServer) Start() error
func (*GRPCIndexServer) Stop ¶
func (s *GRPCIndexServer) Stop() error
type GRPCIndexService ¶
type GRPCIndexService struct { proto.UnimplementedIndexServer // contains filtered or unexported fields }
func NewGRPCIndexService ¶
func NewGRPCIndexService(indexService *IndexService, certificateFile string, commonName string, logger *zap.Logger) (*GRPCIndexService, error)
func (*GRPCIndexService) AddDocuments ¶
func (s *GRPCIndexService) AddDocuments(ctx context.Context, req *proto.AddDocumentsRequest) (*proto.AddDocumentsResponse, error)
func (*GRPCIndexService) Cluster ¶
func (s *GRPCIndexService) Cluster(ctx context.Context, req *proto.ClusterRequest) (*proto.ClusterResponse, error)
func (*GRPCIndexService) CreateIndex ¶
func (s *GRPCIndexService) CreateIndex(ctx context.Context, req *proto.CreateIndexRequest) (*proto.CreateIndexResponse, error)
func (*GRPCIndexService) DeleteDocuments ¶
func (s *GRPCIndexService) DeleteDocuments(ctx context.Context, req *proto.DeleteDocumentsRequest) (*proto.DeleteDocumentsResponse, error)
func (*GRPCIndexService) DeleteIndex ¶
func (s *GRPCIndexService) DeleteIndex(ctx context.Context, req *proto.DeleteIndexRequest) (*proto.DeleteIndexResponse, error)
func (*GRPCIndexService) LivenessCheck ¶
func (s *GRPCIndexService) LivenessCheck(ctx context.Context, req *proto.LivenessCheckRequest) (*proto.LivenessCheckResponse, error)
func (*GRPCIndexService) Metrics ¶
func (s *GRPCIndexService) Metrics(ctx context.Context, req *proto.MetricsRequest) (*proto.MetricsResponse, error)
func (*GRPCIndexService) ReadinessCheck ¶
func (s *GRPCIndexService) ReadinessCheck(ctx context.Context, req *proto.ReadinessCheckRequest) (*proto.ReadinessCheckResponse, error)
func (*GRPCIndexService) Search ¶
func (s *GRPCIndexService) Search(ctx context.Context, req *proto.SearchRequest) (*proto.SearchResponse, error)
type HTTPIndexServer ¶
type HTTPIndexServer struct {
// contains filtered or unexported fields
}
func (*HTTPIndexServer) Start ¶
func (s *HTTPIndexServer) Start() error
func (*HTTPIndexServer) Stop ¶
func (s *HTTPIndexServer) Stop() error
type IndexService ¶
type IndexService struct {
// contains filtered or unexported fields
}
func NewIndexService ¶
func NewIndexService(cluster *phalanxcluster.Cluster, metastore *phalanxmetastore.Metastore, certificateFile string, commonName string, logger *zap.Logger) (*IndexService, error)
func (*IndexService) AddDocuments ¶
func (s *IndexService) AddDocuments(req *proto.AddDocumentsRequest) (*proto.AddDocumentsResponse, error)
func (*IndexService) Cluster ¶
func (s *IndexService) Cluster(req *proto.ClusterRequest) (*proto.ClusterResponse, error)
func (*IndexService) CreateIndex ¶
func (s *IndexService) CreateIndex(req *proto.CreateIndexRequest) (*proto.CreateIndexResponse, error)
func (*IndexService) DeleteDocuments ¶
func (s *IndexService) DeleteDocuments(req *proto.DeleteDocumentsRequest) (*proto.DeleteDocumentsResponse, error)
func (*IndexService) DeleteIndex ¶
func (s *IndexService) DeleteIndex(req *proto.DeleteIndexRequest) (*proto.DeleteIndexResponse, error)
func (*IndexService) Search ¶
func (s *IndexService) Search(req *proto.SearchRequest) (*proto.SearchResponse, error)
func (*IndexService) Start ¶
func (s *IndexService) Start() error
func (*IndexService) Stop ¶
func (s *IndexService) Stop() error
type Marshaler ¶ added in v0.2.0
type Marshaler struct{}
func NewMarshaler ¶ added in v0.2.0
func NewMarshaler() *Marshaler
func (*Marshaler) ContentType ¶ added in v0.2.0
func (*Marshaler) NewDecoder ¶ added in v0.2.0
func (*Marshaler) NewEncoder ¶ added in v0.2.0
Click to show internal directories.
Click to hide internal directories.