Method searchGRPC

cmd/tempo-cli/cmd-query-search.go:63–103

(req *tempopb.SearchRequest)

}

func (cmd *querySearchCmd) searchGRPC(req *tempopb.SearchRequest) error {
	ctx := user.InjectOrgID(context.Background(), cmd.OrgID)
	ctx, err := user.InjectIntoGRPCRequest(ctx)
	if err != nil {
		return err
	}
	ctx = applyHeadersGRPC(ctx, cmd.Headers)

	creds, err := grpcTransportCredentials(cmd.Secure)
	if err != nil {
		return err
	}

	clientConn, err := grpc.NewClient(cmd.HostPort, creds)
	if err != nil {
		return err
	}

	client := tempopb.NewStreamingQuerierClient(clientConn)

	resp, err := client.Search(ctx, req)
	if err != nil {
		return err
	}

	for {
		searchResp, err := resp.Recv()
		if searchResp != nil {
			err = printAsJSON(searchResp)
			if err != nil {
				return err
			}
		}
		if errors.Is(err, io.EOF) {
			return nil
		}
		if err != nil {
			return err
		}
	}
}

// nolint: goconst // goconst wants us to make http:// a const
func (cmd *querySearchCmd) searchHTTP(req *tempopb.SearchRequest) error {